Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for REPLICA (0.04 sec)

  1. internal/bucket/replication/rule_test.go

    			opts:           ObjectOpts{Name: "c1test", DeleteMarker: false, OpType: ObjectReplicationType, Replica: false}, // 1. Replica mod sync enabled; not a replica
    			expectedResult: true,
    		},
    		// case 2 - rule with replica modification disabled; a replica
    		{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. cmd/bucket-object-lock.go

    	}
    
    	opts, err := getOpts(ctx, rq, bucket, object)
    	if err != nil {
    		return mode, retainDate, legalHold, toAPIErrorCode(ctx, err)
    	}
    
    	replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String()
    
    	if opts.VersionID != "" && !replica {
    		if objInfo, err := getObjectInfoFn(ctx, bucket, object, opts); err == nil {
    			r := objectlock.GetObjectRetentionMeta(objInfo.UserDefined)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:25 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  3. docs/bucket/replication/README.md

    ## Replica Modification sync
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  4. internal/bucket/replication/datatypes.go

    	// CompletedLegacy was called "COMPLETE" incorrectly.
    	CompletedLegacy StatusType = "COMPLETE"
    
    	// Failed - replication failed.
    	Failed StatusType = "FAILED"
    
    	// Replica - this is a replica.
    	Replica StatusType = "REPLICA"
    )
    
    // String returns string representation of status
    func (s StatusType) String() string {
    	return string(s)
    }
    
    // Empty returns true if this status is not set
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        if (replica.containsKey(newValue)) {
          replica.get(newValue).incrementAndGet();
        } else {
          replica.put(newValue, new AtomicInteger(1));
        }
      }
    
      private static void removeMinFromReplica(
          SortedMap<Integer, AtomicInteger> replica, int minValue) {
        Integer replicatedMinValue = replica.firstKey();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  6. docs/bucket/replication/DESIGN.md

    replication is configured, any incoming uploads and metadata changes to versions created on the target, will sync back to the source and be marked as `REPLICA` on the source. AWS, as well as MinIO do not by default sync metadata changes on a object version marked `REPLICA` back to source. This requires a setting in the replication configuration called [replica modification sync](https://aws.amazon.com/about-aws/whats-new/2020/12/amazon-s3-replication-adds-support-two-way-replication/).
    
    For active-active...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. internal/bucket/replication/rule.go

    	}
    	return r.ExistingObjectReplication.Validate()
    }
    
    // MetadataReplicate  returns true if object is not a replica or in the case of replicas,
    // replica modification sync is enabled.
    func (r Rule) MetadataReplicate(obj ObjectOpts) bool {
    	if !obj.Replica {
    		return true
    	}
    	return obj.Replica && r.SourceSelectionCriteria.ReplicaModifications.Status == Enabled
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  8. cmd/bucket-replication-utils_test.go

    		},
    		expStatus: replication.Failed,
    	},
    	{ // 5. replication status for replica version
    		name:      "replication status for replica version",
    		rs:        ReplicationState{ReplicationStatusInternal: string(replication.Replica)},
    		expStatus: replication.Replica,
    	},
    }
    
    func TestCompositeReplicationStatus(t *testing.T) {
    	for i, test := range replicationStateTest {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  9. cmd/site-replication-metrics.go

    	for k, v := range o.ErrCounts {
    		n.ErrCounts[k] += v
    	}
    	return n
    }
    
    // SRStats has replication stats at site level
    type SRStats struct {
    	// Total Replica size in bytes
    	ReplicaSize int64 `json:"replicaSize"`
    	// Total Replica received
    	ReplicaCount int64                `json:"replicaCount"`
    	M            map[string]*SRStatus `json:"srStatusMap"`
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  10. cmd/bucket-stats.go

    	ReplicatedSize int64 `json:"completedReplicationSize"`
    	// Total Replica size in bytes
    	ReplicaSize int64 `json:"replicaSize"`
    	// Total failed operations including metadata updates for various time frames
    	Failed madmin.TimedErrStats `json:"failed"`
    
    	// Total number of completed operations
    	ReplicatedCount int64 `json:"replicationCount"`
    	// Total number of replica received
    	ReplicaCount int64 `json:"replicaCount"`
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.5K bytes
    - Viewed (0)
Back to top