- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for resyncTarget (0.34 sec)
-
cmd/bucket-replication-utils_gen_test.go
} } func BenchmarkMarshalMsgResyncTarget(b *testing.B) { v := ResyncTarget{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgResyncTarget(b *testing.B) { v := ResyncTarget{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 23K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} // ResyncTargetsInfo holds a slice of targets with resync info per target type ResyncTargetsInfo struct { Targets []ResyncTarget `json:"target,omitempty"` } // ResyncTarget is a struct representing the Target reset ID where target is identified by its Arn type ResyncTarget struct { Arn string `json:"arn"` ResetID string `json:"resetid"` StartTime time.Time `json:"startTime"`Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 26.1K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
func (z ResyncStatusType) Msgsize() (s int) { s = msgp.IntSize return } // DecodeMsg implements msgp.Decodable func (z *ResyncTarget) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 59.3K bytes - Viewed (0) -
cmd/bucket-replication.go
} if !d.Replicate { continue } r.targets[d.Arn] = resyncTarget(oi, tgt.Arn, tgt.ResetID, tgt.ResetBeforeDate, tgtStatuses[tgt.Arn]) } return r } func targetResetHeader(arn string) string { return fmt.Sprintf("%s-%s", ReservedMetadataPrefixLower+ReplicationReset, arn) }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 118.2K bytes - Viewed (0)