type leaderMetricsAdapter … type LeaderMetric … type noopMetric … func (noopMetric) On(name string) { … } func (noopMetric) Off(name string) { … } func (noopMetric) SlowpathExercised(name string) { … } type defaultLeaderMetrics … func (m *defaultLeaderMetrics) leaderOn(name string) { … } func (m *defaultLeaderMetrics) leaderOff(name string) { … } func (m *defaultLeaderMetrics) slowpathExercised(name string) { … } type noMetrics … func (noMetrics) leaderOn(name string) { … } func (noMetrics) leaderOff(name string) { … } func (noMetrics) slowpathExercised(name string) { … } type MetricsProvider … type noopMetricsProvider … func (noopMetricsProvider) NewLeaderMetric() LeaderMetric { … } var globalMetricsFactory … type leaderMetricsFactory … func (f *leaderMetricsFactory) setProvider(mp MetricsProvider) { … } func (f *leaderMetricsFactory) newLeaderMetrics() leaderMetricsAdapter { … } // SetProvider sets the metrics provider for all subsequently created work // queues. Only the first call has an effect. func SetProvider(metricsProvider MetricsProvider) { … }
Codebase Browser
kubernetes