Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for xBuckets (0.07 sec)

  1. cmd/site-replication.go

    				}
    				return info, errSRBackendIssue(err)
    			}
    			buckets = append(buckets, bi)
    		} else {
    			buckets, err = objAPI.ListBuckets(ctx, BucketOptions{Deleted: opts.ShowDeleted})
    			if err != nil {
    				return info, errSRBackendIssue(err)
    			}
    		}
    		info.Buckets = make(map[string]madmin.SRBucketInfo, len(buckets))
    		for _, bucketInfo := range buckets {
    			bucket := bucketInfo.Name
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    	servers = append(servers, local)
    
    	var poolsInfo map[int]map[int]madmin.ErasureSetInfo
    	var backend madmin.ErasureBackend
    
    	mode := madmin.ItemInitializing
    
    	buckets := madmin.Buckets{}
    	objects := madmin.Objects{}
    	versions := madmin.Versions{}
    	deleteMarkers := madmin.DeleteMarkers{}
    	usage := madmin.Usage{}
    
    	objectAPI := newObjectLayerFn()
    	if objectAPI != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    }
    
    // initResync - initializes bucket replication resync for all buckets.
    func (p *ReplicationPool) initResync(ctx context.Context, buckets []string, objAPI ObjectLayer) error {
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    	// Load bucket metadata sys in background
    	go p.startResyncRoutine(ctx, buckets, objAPI)
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  4. cmd/server_test.go

    		0, nil, s.accessKey, s.secretKey, s.signer)
    	c.Assert(err, nil)
    	// execute the HTTP request to list buckets.
    	response, err := s.client.Do(request)
    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	// create HTTP request for listing buckets.
    	request, err = newTestSignedRequest(http.MethodGet, getListBucketURL(s.endPoint),
    		0, nil, s.accessKey, s.secretKey, s.signer)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    	rcfg, _ := globalBucketObjectLockSys.Get(bucket)
    	if rcfg.LockEnabled && opts.DeletePrefix {
    		apiErr := toAPIError(ctx, errInvalidArgument)
    		apiErr.Description = "force-delete is forbidden on Object Locking enabled buckets"
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    
    	os := newObjSweeper(bucket, object).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    }
    
    func getClusterBucketsTotalMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: bucketsSubsystem,
    		Name:      total,
    		Help:      "Total number of buckets in the cluster",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterCapacityTotalBytesMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: capacityRawSubsystem,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top