type WebhookRejectionErrorType … const namespace … const subsystem … const WebhookRejectionCallingWebhookError … const WebhookRejectionAPIServerInternalError … const WebhookRejectionNoError … var latencySummaryMaxAge … var Metrics … type ObserverFunc … const kindWebhook … const kindPolicy … const stepValidate … const stepAdmit … // WithControllerMetrics is a decorator for named admission handlers. func WithControllerMetrics(i admission.Interface, name string) admission.Interface { … } // WithStepMetrics is a decorator for a whole admission phase, i.e. admit or validation.admission step. func WithStepMetrics(i admission.Interface) admission.Interface { … } // WithMetrics is a decorator for admission handlers with a generic observer func. func WithMetrics(i admission.Interface, observer ObserverFunc, extraLabels ...string) admission.Interface { … } type pluginHandlerWithMetrics … // Admit performs a mutating admission control check and emit metrics. func (p pluginHandlerWithMetrics) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error { … } // Validate performs a non-mutating admission control check and emits metrics. func (p pluginHandlerWithMetrics) Validate(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error { … } type AdmissionMetrics … // newAdmissionMetrics create a new AdmissionMetrics, configured with default metric names. func newAdmissionMetrics() *AdmissionMetrics { … } func (m *AdmissionMetrics) reset() { … } // ObserveAdmissionStep records admission related metrics for a admission step, identified by step type. func (m *AdmissionMetrics) ObserveAdmissionStep(ctx context.Context, elapsed time.Duration, rejected bool, attr admission.Attributes, stepType string, extraLabels ...string) { … } // ObserveAdmissionController records admission related metrics for a built-in admission controller, identified by it's plugin handler name. func (m *AdmissionMetrics) ObserveAdmissionController(ctx context.Context, elapsed time.Duration, rejected bool, attr admission.Attributes, stepType string, extraLabels ...string) { … } // ObserveWebhook records admission related metrics for a admission webhook. func (m *AdmissionMetrics) ObserveWebhook(ctx context.Context, name string, elapsed time.Duration, rejected bool, attr admission.Attributes, stepType string, code int) { … } // ObserveWebhookRejection records admission related metrics for an admission webhook rejection. func (m *AdmissionMetrics) ObserveWebhookRejection(ctx context.Context, name, stepType, operation string, errorType WebhookRejectionErrorType, rejectionCode int) { … } // ObserveWebhookFailOpen records validating or mutating webhook that fail open. func (m *AdmissionMetrics) ObserveWebhookFailOpen(ctx context.Context, name, stepType string) { … } // ObserveMatchConditionEvalError records validating or mutating webhook that are not called due to match conditions func (m *AdmissionMetrics) ObserveMatchConditionEvalError(ctx context.Context, name, kind, stepType, operation string) { … } // ObserveMatchConditionExclusion records validating or mutating webhook that are not called due to match conditions func (m *AdmissionMetrics) ObserveMatchConditionExclusion(ctx context.Context, name, kind, stepType, operation string) { … } // ObserveMatchConditionEvaluationTime records duration of match condition evaluation process. func (m *AdmissionMetrics) ObserveMatchConditionEvaluationTime(ctx context.Context, elapsed time.Duration, name, kind, stepType, operation string) { … } type metricSet … // MustRegister registers all the prometheus metrics in the metricSet. func (m *metricSet) mustRegister() { … } // Reset resets all the prometheus metrics in the metricSet. func (m *metricSet) reset() { … } // Observe records an observed admission event to all metrics in the metricSet. func (m *metricSet) observe(ctx context.Context, elapsed time.Duration, labels ...string) { … }
Codebase Browser
kubernetes