- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newLeaderMetrics (0.21 sec)
-
pilot/pkg/leaderelection/k8sleaderelection/metrics.go
onlyOnce sync.Once } func (f *leaderMetricsFactory) setProvider(mp MetricsProvider) { f.onlyOnce.Do(func() { f.metricsProvider = mp }) } func (f *leaderMetricsFactory) newLeaderMetrics() leaderMetricsAdapter { mp := f.metricsProvider if mp == (noopMetricsProvider{}) { return noMetrics{} } return &defaultLeaderMetrics{ leader: mp.NewLeaderMetric(), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
} if lec.Lock == nil { return nil, fmt.Errorf("lock must not be nil") } le := LeaderElector{ config: lec, clock: clock.RealClock{}, metrics: globalMetricsFactory.newLeaderMetrics(), } le.metrics.leaderOff(le.config.Name) return &le, nil } type KeyComparisonFunc func(existingKey string) bool type LeaderElectionConfig struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0)