Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for listAllBuckets (0.11 sec)

  1. cmd/peer-s3-server.go

    	globalLocalDrivesMu.RUnlock()
    
    	quorum := (len(localDrives) / 2)
    
    	buckets = make([]BucketInfo, 0, 32)
    	healBuckets := map[string]VolInfo{}
    
    	// lists all unique buckets across drives.
    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    	deletedBuckets := map[string]VolInfo{}
    
    	if opts.Deleted {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    	if err := listPathRaw(ctx, lopts); err != nil {
    		return fmt.Errorf("listPathRaw returned %w: opts(%#v)", err, lopts)
    	}
    
    	return nil
    }
    
    // listAllBuckets lists all buckets from all disks. It also
    // returns the occurrence of each buckets in all disks
    func listAllBuckets(ctx context.Context, storageDisks []StorageAPI, healBuckets map[string]VolInfo, readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	var mu sync.Mutex
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  3. cmd/auth-handler.go

    	bucket := reqInfo.BucketName
    	object := reqInfo.ObjectName
    	versionID := reqInfo.VersionID
    
    	if action != policy.ListAllMyBucketsAction && cred.AccessKey == "" {
    		// Anonymous checks are not meant for ListAllBuckets action
    		if globalPolicySys.IsAllowed(policy.BucketPolicyArgs{
    			AccountName:     cred.AccessKey,
    			Groups:          cred.Groups,
    			Action:          action,
    			BucketName:      bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top