- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for listAllBuckets (0.06 sec)
-
cmd/peer-s3-server.go
quorum := (len(localDrives) / 2) buckets = make([]BucketInfo, 0, 32) healBuckets := xsync.NewMapOf[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 := xsync.NewMapOf[string, VolInfo]() if opts.Deleted {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
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 *xsync.MapOf[string, VolInfo], readQuorum int) error { g := errgroup.WithNErrs(len(storageDisks))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0)