- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for ReplicatedCount (0.19 sec)
-
cmd/data-usage-cache_gen.go
return } z.AfterThresholdCount, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "AfterThresholdCount") return } z.ReplicatedCount, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "ReplicatedCount") return } return } // EncodeMsg implements msgp.Encodable func (z *replicationStats) EncodeMsg(en *msgp.Writer) (err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
ResetID: st.ResyncID, StartTime: st.StartTime, EndTime: st.LastUpdate, ResyncStatus: st.ResyncStatus.String(), ReplicatedSize: st.ReplicatedSize, ReplicatedCount: st.ReplicatedCount, FailedSize: st.FailedSize, FailedCount: st.FailedCount, Bucket: st.Bucket, Object: st.Object, }) } data, err := json.Marshal(rinfo)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
// Failed size in bytes FailedSize int64 `json:"failedReplicationSize"` // Total number of failed operations FailedCount int64 `json:"failedReplicationCount"` // Total number of failed operations ReplicatedCount int64 `json:"replicationCount"` // Last bucket/object replicated. Bucket string `json:"bucket,omitempty"` Object string `json:"object,omitempty"` }
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) -
cmd/bucket-replication.go
s.Lock() defer s.Unlock() m := s.statusMap[opts.bucket] st := m.TargetsMap[opts.arn] st.Object = ts.Object st.ReplicatedCount += ts.ReplicatedCount st.FailedCount += ts.FailedCount st.ReplicatedSize += ts.ReplicatedSize st.FailedSize += ts.FailedSize m.TargetsMap[opts.arn] = st m.LastUpdate = UTCNow() s.statusMap[opts.bucket] = m
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) -
cmd/metrics-v2.go
VariableLabels: map[string]string{"endpoint": stat.Endpoint}, }) ml = append(ml, MetricV2{ Description: getRepSentOperationsMD(clusterMetricNamespace), Value: float64(stat.ReplicatedCount), VariableLabels: map[string]string{"endpoint": stat.Endpoint}, }) if c, ok := stat.Failed.ErrCounts["AccessDenied"]; ok { ml = append(ml, MetricV2{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/site-replication.go
v2.LastOnline = v.LastOnline v2.Latency = v.Latency v2.Online = v.Online v2.TotalDowntime = v.TotalDowntime v2.DeploymentID = v.DeploymentID } v2.ReplicatedCount += v.ReplicatedCount v2.ReplicatedSize += v.ReplicatedSize v2.Failed = v2.Failed.Add(v.Failed) for k, v := range v.Failed.ErrCounts { v2.Failed.ErrCounts[k] += v } if v2.XferStats == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/xl-storage.go
} for tgt, st := range sizeS.replTargetStats { res["repl-size-"+tgt] = strconv.FormatInt(st.replicatedSize, 10) res["repl-count-"+tgt] = strconv.FormatInt(st.replicatedCount, 10) if st.failedCount > 0 { res["repl-failed-"+tgt] = fmt.Sprintf("%d versions, %d bytes", st.failedCount, st.failedSize) } if st.pendingCount > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0)