Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for makeBucketLocal (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top