Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getReplicationState (1.04 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,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	eventName := event.ObjectReplicationComplete
    	if replicationStatus == replication.Failed {
    		eventName = event.ObjectReplicationFailed
    		globalReplicationPool.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{
    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)
Back to top