- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RecordMetrics (0.18 sec)
-
pilot/pkg/networking/core/envoyfilter/monitoring.go
func IncrementEnvoyFilterErrorMetric(pt PatchType) { if !features.EnableEnvoyFilterMetrics { return } envoyFilterStatus.With(patchType.Value(string(pt))).With(resultType.Value(string(Error))).Record(1) } func RecordMetrics() { if !features.EnableEnvoyFilterMetrics { return } envoyFilterMutex.RLock() defer envoyFilterMutex.RUnlock() for name, pmap := range envoyFilterStatusMap { for pt, applied := range pmap {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
return true } c.queue.Forget(key) return true } func (c *Publisher) syncNamespace(ctx context.Context, ns string) (err error) { startTime := time.Now() defer func() { recordMetrics(startTime, err) klog.FromContext(ctx).V(4).Info("Finished syncing namespace", "namespace", ns, "elapsedTime", time.Since(startTime)) }() cm, err := c.cmLister.ConfigMaps(ns).Get(RootCACertConfigMapName) switch {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
} // Reset the status during the push. oldPushContext := s.globalPushContext() if oldPushContext != nil { oldPushContext.OnConfigChange() // Push the previous push Envoy metrics. envoyfilter.RecordMetrics() } // PushContext is reset after a config change. Previous status is // saved. t0 := time.Now() versionLocal := s.NextVersion() push, err := s.initPushContext(req, oldPushContext, versionLocal)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)