metrics

Documentation

Index

• Constants
• func AddMetricsTransportWrapper(metrics *CustomMetrics, config *rest.Config) *rest.Config
• type CustomMetrics
  • func RegisterCustomMetrics() *CustomMetrics
  • func (m *CustomMetrics) DecISBServiceRollouts(name, namespace string)
  • func (m *CustomMetrics) DecMonoVertexRollouts(name, namespace string)
  • func (m *CustomMetrics) DecPipelineROsRunning(name, namespace string)
  • func (m *CustomMetrics) IncISBServiceRollouts(name, namespace string)
  • func (m *CustomMetrics) IncMonoVertexRollouts(name, namespace string)
  • func (m *CustomMetrics) IncPipelineROsRunning(name, namespace string)

Constants

const (
	LabelIntuit             = "intuit_alert"
	LabelVersion            = "version"
	LabelType               = "type"
	LabelPhase              = "phase"
	LabelK8SVersion         = "K8SVersion"
	LabelName               = "name"
	LabelNamespace          = "namespace"
	LabelPipeline           = "pipeline"
	LabelISBService         = "isbservice"
	LabelNumaflowController = "numaflowcontroller"
	LabelMonoVertex         = "monovertex"
	LabelPauseType          = "pause_type"
)

Functions

func AddMetricsTransportWrapper

func AddMetricsTransportWrapper(metrics *CustomMetrics, config *rest.Config) *rest.Config

AddMetricsTransportWrapper adds a transport wrapper which increments 'numaplane_app_k8s_request_total' counter on each kubernetes request

Types

type CustomMetrics

type CustomMetrics struct {
	// PipelinesRolloutHealth is the gauge for the health of pipelines.
	PipelinesRolloutHealth *prometheus.GaugeVec
	// PipelineRolloutsRunning is the gauge for the number of running PipelineRollouts.
	PipelineRolloutsRunning *prometheus.GaugeVec
	// PipelineROCounterMap contains the information of all running PipelineRollouts.
	PipelineROCounterMap map[string]map[string]struct{}
	// PipelineROSyncErrors is the counter for the total number of sync errors.
	PipelineROSyncErrors *prometheus.CounterVec
	// PipelineRolloutQueueLength is the gauge for the length of pipeline rollout queue.
	PipelineRolloutQueueLength *prometheus.GaugeVec
	// PipelineROSyncs is the counter for the total number of PipelineRollout reconciliations
	PipelineROSyncs *prometheus.CounterVec
	// ISBServicesRolloutHealth is the gauge for the health of ISBServiceRollouts.
	ISBServicesRolloutHealth *prometheus.GaugeVec
	// ISBServiceRolloutsRunning is the gauge for the number of running ISBServiceRollouts.
	ISBServiceRolloutsRunning *prometheus.GaugeVec
	// ISBServiceROCounterMap contains the information of all running ISBServiceRollouts.
	ISBServiceROCounterMap map[string]map[string]struct{}
	// ISBServicesROSyncErrors is the counter for the total number of ISBServiceRollout reconciliation errors
	ISBServicesROSyncErrors *prometheus.CounterVec
	// ISBServiceROSyncs is the counter for the total number of ISBServiceRollout reconciliations
	ISBServiceROSyncs *prometheus.CounterVec
	// MonoVerticesRolloutHealth is the gauge for the health of MonoVertexRollout.
	MonoVerticesRolloutHealth *prometheus.GaugeVec
	// MonoVertexRolloutsRunning is the gauge for the number of running MonoVertexRollouts.
	MonoVertexRolloutsRunning *prometheus.GaugeVec
	// MonoVerticesCounterMap contains the information of all running MonoVertexRollouts.
	MonoVerticesCounterMap map[string]map[string]struct{}
	// MonoVertexROSyncErrors is the counter for the total number of MonoVertexRollout reconciliation errors
	MonoVertexROSyncErrors *prometheus.CounterVec
	// MonoVertexROSyncs is the counter for the total number of MonoVertexRollout reconciliations
	MonoVertexROSyncs *prometheus.CounterVec
	// NumaflowControllersRolloutHealth is the gauge for the health of NumaflowControllerRollouts.
	NumaflowControllersRolloutHealth *prometheus.GaugeVec
	// NumaflowControlleRORunning is the gauge for the number of running NumaflowControllerRollouts with a specific version.
	NumaflowControlleRORunning *prometheus.GaugeVec
	// NumaflowControllerROSyncErrors is the counter for the total number of NumaflowControllerRollout reconciliation errors
	NumaflowControllerROSyncErrors *prometheus.CounterVec
	// NumaflowControllersROSyncs in the counter for the total number of NumaflowControllerRollout reconciliations
	NumaflowControllersROSyncs *prometheus.CounterVec
	// ReconciliationDuration is the histogram for the duration of pipeline, isb service, monovertex and numaflow controller reconciliation.
	ReconciliationDuration *prometheus.HistogramVec
	// NumaflowControllerKubectlExecutionCounter Count the number of kubectl executions during numaflow controller reconciliation
	NumaflowControllerKubectlExecutionCounter *prometheus.CounterVec
	// KubeRequestCounter Count the number of kubernetes requests during reconciliation
	KubeRequestCounter *prometheus.CounterVec
	// KubeResourceMonitored count the number of monitored kubernetes resource objects in cache
	KubeResourceMonitored *prometheus.GaugeVec
	// KubeResourceCache count the number of kubernetes resource objects in cache
	KubeResourceCache *prometheus.GaugeVec
	// ClusterCacheError count the total number of cluster cache errors
	ClusterCacheError *prometheus.CounterVec
	// PipelinePausedSeconds counts the total time a Pipeline was paused.
	PipelinePausedSeconds *prometheus.GaugeVec
	// PipelinePausingSeconds counts the total time a Pipeline was pausing.
	PipelinePausingSeconds *prometheus.GaugeVec
	// ISBServicePausedSeconds counts the total time an ISBService requested resources be paused.
	ISBServicePausedSeconds *prometheus.GaugeVec
	// NumaflowControllerPausedSeconds counts the total time a Numaflow controller requested resources be paused.
	NumaflowControllerPausedSeconds *prometheus.GaugeVec
}

func RegisterCustomMetrics

func RegisterCustomMetrics() *CustomMetrics

RegisterCustomMetrics registers the custom metrics to the existing global prometheus registry for pipelines, ISB service and numaflow controller

func (*CustomMetrics) DecISBServiceRollouts

func (m *CustomMetrics) DecISBServiceRollouts(name, namespace string)

DecISBServiceRollouts decrements the ISBServiceRollout counter

func (*CustomMetrics) DecMonoVertexRollouts

func (m *CustomMetrics) DecMonoVertexRollouts(name, namespace string)

DecMonoVertexRollouts decrements the MonoVertexRollout counter

func (*CustomMetrics) DecPipelineROsRunning

func (m *CustomMetrics) DecPipelineROsRunning(name, namespace string)

DecPipelineROsRunning decrements the PipelineRollout counter

func (*CustomMetrics) IncISBServiceRollouts

func (m *CustomMetrics) IncISBServiceRollouts(name, namespace string)

IncISBServiceRollouts increments the ISBServiceRollout counter if it doesn't already know about it

func (*CustomMetrics) IncMonoVertexRollouts

func (m *CustomMetrics) IncMonoVertexRollouts(name, namespace string)

IncMonoVertexRollouts increments the MonoVertexRollout counter if it doesn't already know about it

func (*CustomMetrics) IncPipelineROsRunning

func (m *CustomMetrics) IncPipelineROsRunning(name, namespace string)

IncPipelineROsRunning increments the PipelineRollout counter if it doesn't already know about it