metricscollector

package

Go to main page

Versions in this module

v2

v2.14.0

Apr 25, 2024

Changes in this version

+ func GetServerMetrics() *grpcprom.ServerMetrics

+ func PausedStatusCallback(_ context.Context, obsrv api.Float64Observer) error

+ func ScalableObjectLatencyCallbackDeprecated(_ context.Context, obsrv api.Float64Observer) error

+ func ScalerMetricsLatencyCallbackDeprecated(_ context.Context, obsrv api.Float64Observer) error

v2.13.1

Feb 29, 2024

v2.13.0

Jan 18, 2024

Changes in this version

+ const CloudEventSourceResource

+ func BuildInfoCallback(_ context.Context, obsrv api.Int64Observer) error

+ func CloudeventQueueStatusCallback(_ context.Context, obsrv api.Float64Observer) error

+ func RecordCloudEventEmitted(namespace string, cloudeventsource string, eventsink string)

+ func RecordCloudEventEmittedError(namespace string, cloudeventsource string, eventsink string)

+ func RecordCloudEventQueueStatus(namespace string, value int)

+ func RecordScaledJobError(namespace string, scaledJob string, err error)

+ func RecordScaledObjectPaused(namespace string, scaledObject string, active bool)

+ func ScalableObjectLatencyCallback(_ context.Context, obsrv api.Float64Observer) error

+ func ScalerActiveCallback(_ context.Context, obsrv api.Float64Observer) error

+ func ScalerMetricValueCallback(_ context.Context, obsrv api.Float64Observer) error

+ func ScalerMetricsLatencyCallback(_ context.Context, obsrv api.Float64Observer) error

type MetricsCollector

+ RecordCloudEventEmitted func(namespace string, cloudeventsource string, eventsink string)

+ RecordCloudEventEmittedError func(namespace string, cloudeventsource string, eventsink string)

+ RecordCloudEventQueueStatus func(namespace string, value int)

+ RecordScaledJobError func(namespace string, scaledJob string, err error)

+ RecordScaledObjectPaused func(namespace string, scaledObject string, active bool)

+ type OtelMetricFloat64Val struct

+ type OtelMetricInt64Val struct

type OtelMetrics

+ func (o *OtelMetrics) RecordCloudEventEmitted(namespace string, cloudeventsource string, eventsink string)

+ func (o *OtelMetrics) RecordCloudEventEmittedError(namespace string, cloudeventsource string, eventsink string)

+ func (o *OtelMetrics) RecordCloudEventQueueStatus(namespace string, value int)

+ func (o *OtelMetrics) RecordScaledJobError(namespace string, scaledJob string, err error)

+ func (o *OtelMetrics) RecordScaledObjectPaused(namespace string, scaledObject string, active bool)

type PromMetrics

+ func (p *PromMetrics) RecordCloudEventEmitted(namespace string, cloudeventsource string, eventsink string)

+ func (p *PromMetrics) RecordCloudEventEmittedError(namespace string, cloudeventsource string, eventsink string)

+ func (p *PromMetrics) RecordCloudEventQueueStatus(namespace string, value int)

+ func (p *PromMetrics) RecordScaledJobError(namespace string, scaledJob string, err error)

+ func (p *PromMetrics) RecordScaledObjectPaused(namespace string, scaledObject string, active bool)

v2.12.1

Nov 27, 2023

v2.12.0

Sep 28, 2023

Changes in this version

+ const ClusterTriggerAuthenticationResource

+ const DefaultPromMetricsNamespace

+ const ScaledJobResource

+ const ScaledObjectResource

+ const TriggerAuthenticationResource

+ func DecrementCRDTotal(crdType, namespace string)

+ func DecrementTriggerTotal(triggerType string)

+ func IncrementCRDTotal(crdType, namespace string)

+ func IncrementTriggerTotal(triggerType string)

+ func NewMetricsCollectors(enablePrometheusMetrics bool, enableOpenTelemetryMetrics bool)

+ func RecordBuildInfo()

+ func RecordScalableObjectLatency(namespace string, name string, isScaledObject bool, value float64)

+ func RecordScaledObjectError(namespace string, scaledObject string, err error)

+ func RecordScalerActive(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func RecordScalerError(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func RecordScalerLatency(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func RecordScalerMetric(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ type MetricsCollector interface

+ DecrementCRDTotal func(crdType, namespace string)

+ DecrementTriggerTotal func(triggerType string)

+ IncrementCRDTotal func(crdType, namespace string)

+ IncrementTriggerTotal func(triggerType string)

+ RecordScalableObjectLatency func(namespace string, name string, isScaledObject bool, value float64)

+ RecordScaledObjectError func(namespace string, scaledObject string, err error)

+ RecordScalerActive func(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ RecordScalerError func(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ RecordScalerLatency func(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ RecordScalerMetric func(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ type OtelMetrics struct

+ func NewOtelMetrics(options ...metric.Option) *OtelMetrics

+ func (o *OtelMetrics) DecrementCRDTotal(crdType, namespace string)

+ func (o *OtelMetrics) DecrementTriggerTotal(triggerType string)

+ func (o *OtelMetrics) IncrementCRDTotal(crdType, namespace string)

+ func (o *OtelMetrics) IncrementTriggerTotal(triggerType string)

+ func (o *OtelMetrics) RecordBuildInfo()

+ func (o *OtelMetrics) RecordScalableObjectLatency(namespace string, name string, isScaledObject bool, value float64)

+ func (o *OtelMetrics) RecordScaledObjectError(namespace string, scaledObject string, err error)

+ func (o *OtelMetrics) RecordScalerActive(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (o *OtelMetrics) RecordScalerError(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (o *OtelMetrics) RecordScalerLatency(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (o *OtelMetrics) RecordScalerMetric(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ type PromMetrics struct

+ func NewPromMetrics() *PromMetrics

+ func (p *PromMetrics) DecrementCRDTotal(crdType, namespace string)

+ func (p *PromMetrics) DecrementTriggerTotal(triggerType string)

+ func (p *PromMetrics) IncrementCRDTotal(crdType, namespace string)

+ func (p *PromMetrics) IncrementTriggerTotal(triggerType string)

+ func (p *PromMetrics) RecordScalableObjectLatency(namespace string, name string, isScaledObject bool, value float64)

+ func (p *PromMetrics) RecordScaledObjectError(namespace string, scaledObject string, err error)

+ func (p *PromMetrics) RecordScalerActive(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (p *PromMetrics) RecordScalerError(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (p *PromMetrics) RecordScalerLatency(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

+ func (p *PromMetrics) RecordScalerMetric(namespace string, scaledObject string, scaler string, scalerIndex int, ...)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL