Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ReplicationState (0.67 sec)

  1. cmd/bucket-replication-utils.go

    		UserTags:             oi.UserTags,
    	}
    	if r.SSEC {
    		r.Checksum = oi.Checksum
    	}
    	return r
    }
    
    // ReplicationState - returns replication state using other internal replication metadata in ObjectInfo
    func (o ObjectInfo) ReplicationState() ReplicationState {
    	rs := ReplicationState{
    		ReplicationStatusInternal:  o.ReplicationStatusInternal,
    		VersionPurgeStatusInternal: o.VersionPurgeStatusInternal,
    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/erasure-metadata.go

    	if len(tags) != 0 {
    		objInfo.UserTags = tags
    	}
    
    	// Add replication status to the object info
    	objInfo.ReplicationStatusInternal = fi.ReplicationState.ReplicationStatusInternal
    	objInfo.VersionPurgeStatusInternal = fi.ReplicationState.VersionPurgeStatusInternal
    	objInfo.ReplicationStatus = fi.ReplicationStatus()
    	if objInfo.ReplicationStatus.Empty() { // overlay x-amx-replication-status if present for replicas
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgReplicationState(b *testing.B) {
    	v := ReplicationState{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgReplicationState(b *testing.B) {
    	v := ReplicationState{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 22 23:53:06 UTC 2022
    - 23K bytes
    - Viewed (0)
  4. cmd/object-api-datatypes.go

    	ReplicationStatus          replication.StatusType
    	ReplicationStatusInternal  string
    	VersionPurgeStatusInternal string
    	VersionPurgeStatus         VersionPurgeStatusType
    	ReplicationState           ReplicationState
    	DeleteMarker               bool
    
    	OpType               replication.Type
    	EventType            string
    	RetryCount           uint32
    	ResetID              string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    		o.DeleteReplication.PurgeTargets = versionPurgeStatusesMap(o.DeleteReplication.VersionPurgeStatusInternal)
    	}
    }
    
    // PutReplicationState gets ReplicationState for PUT operation from ObjectOptions
    func (o *ObjectOptions) PutReplicationState() (r ReplicationState) {
    	rstatus, ok := o.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus]
    	if !ok {
    		return
    	}
    	r.ReplicationStatusInternal = rstatus
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. cmd/storage-datatypes.go

    	Parts []ObjectPartInfo `msg:"parts"`
    
    	// Erasure info for all objects.
    	Erasure ErasureInfo `msg:"ei"`
    
    	MarkDeleted      bool             `msg:"md"` // mark this version as deleted
    	ReplicationState ReplicationState `msg:"rs"` // Internal replication state to be passed back in ObjectInfo
    
    	Data []byte `msg:"d,allownil"` // optionally carries object data
    
    	NumVersions      int       `msg:"nv"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    						bucket,
    						version.Name,
    						ObjectOptions{
    							Versioned:         true,
    							VersionID:         versionID,
    							MTime:             version.ModTime,
    							DeleteReplication: version.ReplicationState,
    							SrcPoolIdx:        poolIdx,
    							DataMovement:      true,
    							DeleteMarker:      true, // make sure we create a delete marker
    							SkipRebalancing:   true, // make sure we skip the decommissioned pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    							// on the pool being decommissioned.
    							Versioned:          true,
    							VersionID:          versionID,
    							MTime:              version.ModTime,
    							DeleteReplication:  version.ReplicationState,
    							SrcPoolIdx:         idx,
    							DataMovement:       true,
    							DeleteMarker:       true, // make sure we create a delete marker
    							SkipDecommissioned: true, // make sure we skip the decommissioned pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top