Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Sets (0.2 sec)

  1. cmd/bucket-replication.go

    	ObjectLockLegalHoldTimestamp = "objectlock-legalhold-timestamp"
    	// ReplicationWorkerMultiplier is suggested worker multiplier if traffic exceeds replication worker capacity
    	ReplicationWorkerMultiplier = 1.5
    )
    
    // gets replication config associated to a given bucket name.
    func getReplicationConfig(ctx context.Context, bucketName string) (rc *replication.Config, err error) {
    	rCfg, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucketName)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. cmd/object-handlers.go

    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    	if err != nil {
    		// Versioning enabled quite possibly object is deleted might be delete-marker
    		// if present set the headers, no idea why AWS S3 sets these headers.
    		if objInfo.VersionID != "" && objInfo.DeleteMarker {
    			w.Header()[xhttp.AmzVersionID] = []string{objInfo.VersionID}
    			w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(objInfo.DeleteMarker)}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    	creds, err := c.getPeerCreds()
    	if err != nil {
    		return wrapSRErr(err)
    	}
    
    	// The following function, creates a bucket remote and sets up a bucket
    	// replication rule for the given peer.
    	configurePeerFn := func(d string, peer madmin.PeerInfo) error {
    		// Create bucket replication rule to this peer.
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  4. cmd/object-handlers_test.go

    		uploadID          string // uploadID of the transaction.
    		invalidPartNumber bool   // Sets an invalid multipart.
    		maximumPartNumber bool   // Sets a maximum parts.
    		accessKey         string
    		secretKey         string
    		// expected output.
    		expectedRespStatus int
    	}{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    func getClusterWriteQuorumMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: "write",
    		Name:      "quorum",
    		Help:      "Maximum write quorum across all pools and sets",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterHealthStatusMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: "health",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    		}
    		erasureSet, ok := poolInfo[d.SetIndex]
    		if !ok {
    			erasureSet.ID = d.SetIndex
    			cache := dataUsageCache{}
    			if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil {
    				dataUsageInfo := cache.dui(dataUsageRoot, nil)
    				erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount
    				erasureSet.VersionsCount = dataUsageInfo.VersionsTotalCount
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top