Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Liew (1.68 sec)

  1. cmd/erasure-server-pool.go

    		//
    		// GET /testbucket/?list-type=2&delimiter=%2F&max-keys=2&prefix=parquet%2F_SUCCESS%2F&fetch-owner=false
    		//
    		// Here spark is expecting that the List() return empty instead, so from MinIO's point
    		// of view if we simply do a GetObjectInfo() on this prefix by treating it as an object
    		// We save a lot of calls over the network.
    		//
    		// This happens repeatedly for all objects that are created concurrently() avoiding this
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    	if !ok {
    		return nil, errors.New("site replication service account not found")
    	}
    	return &u.Credentials, nil
    }
    
    // listBuckets returns a consistent common view of latest unique buckets across
    // sites, this is used for replication.
    func (c *SiteReplicationSys) listBuckets(ctx context.Context) ([]BucketInfo, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  3. cmd/peer-s3-client.go

    		if err == nil {
    			return healBucketResults[i], nil
    		}
    	}
    
    	return madmin.HealResultItem{}, toObjectErr(errVolumeNotFound, bucket)
    }
    
    // ListBuckets lists buckets across all nodes and returns a consistent view:
    //   - Return an error when a pool cannot return N/2+1 valid bucket information
    //   - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. cmd/notification.go

    		}
    	}
    
    	replicationStats = append(replicationStats, bucketStatsMap)
    	return replicationStats
    }
    
    // GetClusterBucketStats - calls GetClusterBucketStats call on all peers for a cluster statistics view.
    func (sys *NotificationSys) GetClusterBucketStats(ctx context.Context, bucketName string) []BucketStats {
    	ng := WithNPeers(len(sys.peerClients)).WithRetries(1)
    	bucketStats := make([]BucketStats, len(sys.peerClients))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  5. cmd/admin-handlers-users.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    		return
    	}
    
    	checkDenyOnly := false
    	if name == cred.AccessKey {
    		// Check that there is no explicit deny - otherwise it's allowed
    		// to view one's own info.
    		checkDenyOnly = true
    	}
    
    	if !globalIAMSys.IsAllowed(policy.Args{
    		AccountName:     cred.AccessKey,
    		Groups:          cred.Groups,
    		Action:          policy.GetUserAdminAction,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  6. cmd/admin-handlers-pools.go

    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.RebalanceAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	// Proxy rebalance-status to first pool first node, so that users see a
    	// consistent view of rebalance progress even though different rebalancing
    	// pools may temporarily have out of date info on the others.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.9K bytes
    - Viewed (0)
Back to top