- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for TargetReplicationResyncStatus (0.47 sec)
-
cmd/site-replication-utils_gen.go
case "tb": z.TotBuckets, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "TotBuckets") return } case "cst": err = z.TargetReplicationResyncStatus.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "TargetReplicationResyncStatus") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Nov 14 15:16:40 UTC 2022 - 7.2K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen_test.go
} } func BenchmarkMarshalMsgTargetReplicationResyncStatus(b *testing.B) { v := TargetReplicationResyncStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgTargetReplicationResyncStatus(b *testing.B) { v := TargetReplicationResyncStatus{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Aug 22 23:53:06 UTC 2022 - 23K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
return "Failed" case ResyncPending: return "Pending" case ResyncCanceled: return "Canceled" default: return "" } } // TargetReplicationResyncStatus status of resync of bucket for a specific target type TargetReplicationResyncStatus struct { StartTime time.Time `json:"startTime" msg:"st"` LastUpdate time.Time `json:"lastUpdated" msg:"lst"` // Resync ID assigned to this reset
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/site-replication-utils.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (1) -
cmd/bucket-replication-utils_gen.go
return } if z.TargetsMap == nil { z.TargetsMap = make(map[string]TargetReplicationResyncStatus, zb0002) } else if len(z.TargetsMap) > 0 { for key := range z.TargetsMap { delete(z.TargetsMap, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 TargetReplicationResyncStatus za0001, err = dc.ReadString() if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 61.1K bytes - Viewed (0) -
cmd/bucket-replication.go
defer cancel() saveResyncStatus(ctx, opts.bucket, m, objAPI) } // update replication resync stats for bucket's remote target func (s *replicationResyncer) incStats(ts TargetReplicationResyncStatus, opts resyncOpts) { s.Lock() defer s.Unlock() m := s.statusMap[opts.bucket] st := m.TargetsMap[opts.arn] st.Object = ts.Object st.ReplicatedCount += ts.ReplicatedCount
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)