Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for listBucketsLocal (0.34 sec)

  1. cmd/peer-s3-server.go

    		res.After.Drives = append(res.After.Drives, madmin.HealDriveInfo{
    			UUID:     "",
    			Endpoint: localDrives[i].Endpoint().String(),
    			State:    afterState[i],
    		})
    	}
    	return res, nil
    }
    
    func listBucketsLocal(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err 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

    	copy(l.pools, p)
    }
    
    func (l localPeerS3Client) GetPools() []int {
    	return l.pools
    }
    
    func (l localPeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
    	return listBucketsLocal(ctx, opts)
    }
    
    func (l localPeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	return healBucketLocal(ctx, bucket, opts)
    }
    
    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

    	}
    
    	return madminHealResultItem.NewJSONWith(&res), nil
    }
    
    func (s *peerRESTServer) ListBucketsHandler(opts *BucketOptions) (*grid.Array[*BucketInfo], *grid.RemoteErr) {
    	buckets, err := listBucketsLocal(context.Background(), *opts)
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    	res := aoBucketInfo.New()
    	for i := range buckets {
    		bucket := buckets[i]
    		res.Append(&bucket)
    	}
    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