- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for updateMetric (3.53 sec)
-
cmd/bucket-replication.go
resultCh := make(chan TargetReplicationResyncStatus, 1) defer xioutil.SafeClose(resultCh) go func() { for r := range resultCh { s.incStats(r, opts) globalSiteResyncMetrics.updateMetric(r, opts.resyncID) } }() var wg sync.WaitGroup for i := 0; i < resyncParallelRoutines; i++ { wg.Add(1) workers[i] = make(chan ReplicateObjectInfo, 100) i := i
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)