- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for updateMetric (1.97 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) -
pilot/pkg/xds/discovery.go
defer ticker.Stop() for { select { case <-ticker.C: push := s.globalPushContext() model.LastPushMutex.Lock() if model.LastPushStatus != push { model.LastPushStatus = push push.UpdateMetrics() out, _ := model.LastPushStatus.StatusJSON() if string(out) != "{}" { log.Infof("Push Status: %s", string(out)) } } model.LastPushMutex.Unlock() case <-stopCh: return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
func (ps *PushContext) OnConfigChange() { LastPushMutex.Lock() LastPushStatus = ps LastPushMutex.Unlock() ps.UpdateMetrics() } // UpdateMetrics will update the prometheus metrics based on the // current status of the push. func (ps *PushContext) UpdateMetrics() { ps.proxyStatusMutex.RLock() defer ps.proxyStatusMutex.RUnlock() for _, pm := range metrics {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)