- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for makeBucketLocal (0.09 sec)
-
cmd/peer-s3-server.go
} return localDrives[index].DeleteVol(ctx, bucket, opts.Force) }, index) } return reduceWriteQuorumErrs(ctx, g.Wait(), bucketOpIgnoredErrs, (len(localDrives)/2)+1) } func makeBucketLocal(ctx context.Context, bucket string, opts MakeBucketOptions) error { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap) globalLocalDrivesMu.RUnlock()
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/peer-s3-client.go
return getBucketInfoLocal(ctx, bucket, opts) } func (l localPeerS3Client) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error { return makeBucketLocal(ctx, bucket, opts) } func (l localPeerS3Client) DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error { return deleteBucketLocal(ctx, bucket, opts) } // client to talk to peer Nodes.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/peer-rest-server.go
bucket := mss.Get(peerS3Bucket) if isMinioMetaBucket(bucket) { return np, grid.NewRemoteErr(errInvalidArgument) } forceCreate := mss.Get(peerS3BucketForceCreate) == "true" err := makeBucketLocal(context.Background(), bucket, MakeBucketOptions{ ForceCreate: forceCreate, }) if err != nil { return np, grid.NewRemoteErr(err) } return np, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0)