var unavailableGaugeDesc … type Metrics … func New() *Metrics { … } // Register registers apiservice availability metrics. func (m *Metrics) Register( registrationFunc func(metrics.Registerable) error, customRegistrationFunc func(metrics.StableCollector) error, ) error { … } // UnavailableCounter returns a counter to track apiservices marked as unavailable. func (m *Metrics) UnavailableCounter(apiServiceName, reason string) metrics.CounterMetric { … } type availabilityCollector … // SetUnavailableGauge set the metrics so that it reflect the current state base on availability of the given service func (m *Metrics) SetUnavailableGauge(newAPIService *apiregistrationv1.APIService) { … } // SetUnavailableCounter increases the metrics only if the given service is unavailable and its APIServiceCondition has changed func (m *Metrics) SetUnavailableCounter(originalAPIService, newAPIService *apiregistrationv1.APIService) { … } var _ … func newAvailabilityCollector() *availabilityCollector { … } // DescribeWithStability implements the metrics.StableCollector interface. func (c *availabilityCollector) DescribeWithStability(ch chan<- *metrics.Desc) { … } // CollectWithStability implements the metrics.StableCollector interface. func (c *availabilityCollector) CollectWithStability(ch chan<- metrics.Metric) { … } // SetAPIServiceAvailable sets the given apiservice availability gauge to available. func (c *availabilityCollector) SetAPIServiceAvailable(apiServiceKey string) { … } // SetAPIServiceUnavailable sets the given apiservice availability gauge to unavailable. func (c *availabilityCollector) SetAPIServiceUnavailable(apiServiceKey string) { … } func (c *availabilityCollector) setAPIServiceAvailability(apiServiceKey string, availability bool) { … } // ForgetAPIService removes the availability gauge of the given apiservice. func (c *availabilityCollector) ForgetAPIService(apiServiceKey string) { … }
Codebase Browser
kubernetes