- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for RecordMetrics (0.26 sec)
-
pkg/controller/certificates/rootcacertpublisher/metrics.go
Buckets: metrics.ExponentialBuckets(0.001, 2, 15), StabilityLevel: metrics.ALPHA, }, []string{"code"}, ) ) func recordMetrics(start time.Time, err error) { code := "500" if err == nil { code = "200" } else if se, ok := err.(*apierrors.StatusError); ok && se.Status().Code != 0 { code = strconv.Itoa(int(se.Status().Code)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 16 12:05:32 UTC 2021 - 2K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/metrics_test.go
# TYPE root_ca_cert_publisher_sync_total counter root_ca_cert_publisher_sync_total{code="500"} 1 `, }, } for _, tc := range testCases { t.Run(tc.desc, func(t *testing.T) { recordMetrics(time.Now(), tc.err) defer syncCounter.Reset() if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(tc.want), tc.metrics...); err != nil { t.Fatal(err) } }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 16 12:05:32 UTC 2021 - 2.7K bytes - Viewed (0) -
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)