- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ReplicateDecisionStr (0.19 sec)
-
cmd/bucket-replication-utils.go
func getReplicationState(rinfos replicatedInfos, prevState ReplicationState, vID string) ReplicationState { rs := ReplicationState{ ReplicateDecisionStr: prevState.ReplicateDecisionStr, ResetStatusesMap: prevState.ResetStatusesMap, ReplicaTimeStamp: prevState.ReplicaTimeStamp, ReplicaStatus: prevState.ReplicaStatus, } var replStatuses, vpurgeStatuses string
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26K bytes - Viewed (0) -
cmd/bucket-handlers.go
VersionPurgeStatuses: dObjects[i].ReplicationState.VersionPurgeStatusInternal, DeleteMarkerReplicationStatus: dObjects[i].ReplicationState.ReplicationStatusInternal, ReplicateDecisionStr: dObjects[i].ReplicationState.ReplicateDecisionStr, } dindex := objectsToDelete[objToDel] if errs[i] == nil || isErrObjectNotFound(errs[i]) || isErrVersionNotFound(errs[i]) { if replicateDeletes {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
cmd/object-api-interface.go
} // SetDeleteReplicationState sets the delete replication options. func (o *ObjectOptions) SetDeleteReplicationState(dsc ReplicateDecision, vID string) { o.DeleteReplication = ReplicationState{ ReplicateDecisionStr: dsc.String(), } switch o.VersionID { case "": o.DeleteReplication.ReplicationStatusInternal = dsc.PendingStatus()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/bucket-replication.go
}) return } dsc, err := parseReplicateDecision(ctx, bucket, dobj.ReplicationState.ReplicateDecisionStr) if err != nil { replLogOnceIf(ctx, fmt.Errorf("unable to parse replication decision parameters for bucket: %s, err: %s, decision: %s", bucket, err, dobj.ReplicationState.ReplicateDecisionStr), dobj.ReplicationState.ReplicateDecisionStr) sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { return ObjectInfo{}, err } if dsc.ReplicateAny() { opts.SetDeleteReplicationState(dsc, opts.VersionID) goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr } } if opts.EvalRetentionBypassFn != nil { if err := opts.EvalRetentionBypassFn(goi, gerr); err != nil { return ObjectInfo{}, err } } if opts.Expiration.Expire {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0)