Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getReplicationState (0.12 sec)

  1. cmd/bucket-replication-utils.go

    		PrevReplicationStatus: rs.Targets[arn],
    		VersionPurgeStatus:    rs.PurgeTargets[arn],
    		ResyncTimestamp:       rs.ResetStatusesMap[arn],
    	}
    }
    
    // getReplicationState returns replication state using target replicated info for the targets
    func getReplicationState(rinfos replicatedInfos, prevState ReplicationState, vID string) ReplicationState {
    	rs := ReplicationState{
    		ReplicateDecisionStr: prevState.ReplicateDecisionStr,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	eventName := event.ObjectReplicationComplete
    	if replicationStatus == replication.Failed {
    		eventName = event.ObjectReplicationFailed
    		globalReplicationPool.Get().queueMRFSave(dobj.ToMRFEntry())
    	}
    	drs := getReplicationState(rinfos, dobj.ReplicationState, dobj.VersionID)
    	if replicationStatus != prevStatus {
    		drs.ReplicationTimeStamp = UTCNow()
    	}
    
    	dobjInfo, err := objectAPI.DeleteObject(ctx, bucket, dobj.ObjectName, ObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top