Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for CompositeReplicationStatus (0.24 sec)

  1. cmd/bucket-replication-utils.go

    		rs.ReplicationStatusInternal == o.ReplicationStatusInternal &&
    		rs.VersionPurgeStatusInternal == o.VersionPurgeStatusInternal
    }
    
    // CompositeReplicationStatus returns overall replication status for the object version being replicated.
    func (rs *ReplicationState) CompositeReplicationStatus() (st replication.StatusType) {
    	switch {
    	case rs.ReplicationStatusInternal != "":
    		switch replication.StatusType(rs.ReplicationStatusInternal) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	return fi.ReplicationState.CompositeReplicationStatus()
    }
    
    // DeleteMarkerReplicationStatus returns overall replication status for this delete marker version across targets
    func (fi *FileInfo) DeleteMarkerReplicationStatus() replication.StatusType {
    	if fi.Deleted {
    		return fi.ReplicationState.CompositeReplicationStatus()
    	}
    	return replication.StatusType("")
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19K bytes
    - Viewed (1)
  3. cmd/bucket-replication-utils_test.go

    		expStatus: replication.Replica,
    	},
    }
    
    func TestCompositeReplicationStatus(t *testing.T) {
    	for i, test := range replicationStateTest {
    		if rstatus := test.rs.CompositeReplicationStatus(); rstatus != test.expStatus {
    			t.Errorf("Test%d (%s): Overall replication status  got %s , want %s", i+1, test.name, rstatus, test.expStatus)
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 08 20:27:40 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    func (o *ObjectOptions) DeleteMarkerReplicationStatus() replication.StatusType {
    	return o.DeleteReplication.CompositeReplicationStatus()
    }
    
    // VersionPurgeStatus - returns version purge status from DeleteReplication state in ObjectOptions
    func (o *ObjectOptions) VersionPurgeStatus() VersionPurgeStatusType {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2.go

    			fi.Metadata[k] = string(v)
    		}
    	}
    	fi.ReplicationState = getInternalReplicationState(fi.Metadata)
    	fi.Deleted = !fi.VersionPurgeStatus().Empty()
    	replStatus := fi.ReplicationState.CompositeReplicationStatus()
    	if replStatus != "" {
    		fi.Metadata[xhttp.AmzBucketReplicationStatus] = string(replStatus)
    	}
    	fi.Erasure.Algorithm = j.ErasureAlgorithm.String()
    	fi.Erasure.Index = j.ErasureIndex
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 63.6K bytes
    - Viewed (1)
Back to top