Documentation
¶
Index ¶
- Constants
- func AddMetricsTransportWrapper(metrics *CustomMetrics, config *rest.Config) *rest.Config
- type 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) DeleteISBServicesRolloutHealth(namespace, name string)
- func (m *CustomMetrics) DeleteMonoVerticesRolloutHealth(namespace, name string)
- func (m *CustomMetrics) DeleteNumaflowControllerRolloutsHealth(namespace, name string)
- func (m *CustomMetrics) DeleteNumaflowControllersHealth(namespace, name string)
- func (m *CustomMetrics) DeletePipelineRolloutHealth(namespace, name string)
- func (m *CustomMetrics) IncISBServiceRollouts(name, namespace string)
- func (m *CustomMetrics) IncMonoVertexRollouts(name, namespace string)
- func (m *CustomMetrics) IncPipelineROsRunning(name, namespace string)
- func (m *CustomMetrics) SetISBServicesRolloutHealth(namespace, name, currentPhase string)
- func (m *CustomMetrics) SetMonoVerticesRolloutHealth(namespace, name, currentPhase string)
- func (m *CustomMetrics) SetNumaflowControllerRolloutsHealth(namespace, name, currentPhase string)
- func (m *CustomMetrics) SetNumaflowControllersHealth(namespace, name, currentPhase string)
- func (m *CustomMetrics) SetPipelineRolloutHealth(namespace, name, currentPhase string)
Constants ¶
const ( LabelIntuit = "intuit_alert" LabelVersion = "version" LabelType = "type" LabelPhase = "phase" LabelK8SVersion = "K8SVersion" LabelName = "name" LabelNamespace = "namespace" LabelPipeline = "pipeline" LabelISBService = "isbservice" LabelNumaflowControllerRollout = "numaflowcontrollerrollout" LabelNumaflowController = "numaflowcontroller" LabelMonoVertex = "monovertex" LabelPauseType = "pause_type" )
Variables ¶
This section is empty.
Functions ¶
func AddMetricsTransportWrapper ¶ added in v0.4.0
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
// NumaflowControllerRolloutsHealth is the gauge for the health of NumaflowControllerRollouts
NumaflowControllerRolloutsHealth *prometheus.GaugeVec
// NumaflowControllerRolloutsRunning is the gauge for the number of running NumaflowControllerRollouts
NumaflowControllerRolloutsRunning *prometheus.GaugeVec
// NumaflowControllerRolloutSyncErrors is the counter for the total number of NumaflowControllerRollout reconciliation errors
NumaflowControllerRolloutSyncErrors *prometheus.CounterVec
// NumaflowControllerRolloutSyncs is the counter for the total number of NumaflowControllerRollout reconciliations
NumaflowControllerRolloutSyncs *prometheus.CounterVec
// NumaflowControllerRolloutPausedSeconds counts the total time a NumaflowControllerRollout requested resources be paused
NumaflowControllerRolloutPausedSeconds *prometheus.GaugeVec
// NumaflowControllersHealth is the gauge for the health of NumaflowControllers
NumaflowControllersHealth *prometheus.GaugeVec
// NumaflowControllerSyncErrors is the counter for the total number of NumaflowController reconciliation errors
NumaflowControllerSyncErrors *prometheus.CounterVec
// NumaflowControllerSyncs is the counter for the total number of NumaflowController reconciliations
NumaflowControllerSyncs *prometheus.CounterVec
// NumaflowControllerKubectlExecutionCounter counts the number of kubectl executions during a NumaflowController reconciliation
NumaflowControllerKubectlExecutionCounter *prometheus.CounterVec
// ReconciliationDuration is the histogram for the duration of pipeline, isb service, monovertex and numaflow controller reconciliation.
ReconciliationDuration *prometheus.HistogramVec
// 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
}
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 ¶ added in v0.8.0
func (m *CustomMetrics) DecISBServiceRollouts(name, namespace string)
DecISBServiceRollouts decrements the ISBServiceRollout counter
func (*CustomMetrics) DecMonoVertexRollouts ¶ added in v0.8.0
func (m *CustomMetrics) DecMonoVertexRollouts(name, namespace string)
DecMonoVertexRollouts decrements the MonoVertexRollout counter
func (*CustomMetrics) DecPipelineROsRunning ¶ added in v0.8.0
func (m *CustomMetrics) DecPipelineROsRunning(name, namespace string)
DecPipelineROsRunning decrements the PipelineRollout counter
func (*CustomMetrics) DeleteISBServicesRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) DeleteISBServicesRolloutHealth(namespace, name string)
DeleteISBServicesRolloutHealth deletes the ISB service rollout health metric
func (*CustomMetrics) DeleteMonoVerticesRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) DeleteMonoVerticesRolloutHealth(namespace, name string)
DeleteMonoVerticesRolloutHealth deletes the monovertex rollout health metric
func (*CustomMetrics) DeleteNumaflowControllerRolloutsHealth ¶ added in v0.13.0
func (m *CustomMetrics) DeleteNumaflowControllerRolloutsHealth(namespace, name string)
DeleteNumaflowControllerRolloutsHealth deletes the numaflow controller rollout health metric
func (*CustomMetrics) DeleteNumaflowControllersHealth ¶ added in v0.13.0
func (m *CustomMetrics) DeleteNumaflowControllersHealth(namespace, name string)
DeleteNumaflowControllersHealth deletes the numaflow controller health metric
func (*CustomMetrics) DeletePipelineRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) DeletePipelineRolloutHealth(namespace, name string)
DeletePipelineRolloutHealth deletes the pipeline rollout health metric
func (*CustomMetrics) IncISBServiceRollouts ¶ added in v0.8.0
func (m *CustomMetrics) IncISBServiceRollouts(name, namespace string)
IncISBServiceRollouts increments the ISBServiceRollout counter if it doesn't already know about it
func (*CustomMetrics) IncMonoVertexRollouts ¶ added in v0.8.0
func (m *CustomMetrics) IncMonoVertexRollouts(name, namespace string)
IncMonoVertexRollouts increments the MonoVertexRollout counter if it doesn't already know about it
func (*CustomMetrics) IncPipelineROsRunning ¶ added in v0.8.0
func (m *CustomMetrics) IncPipelineROsRunning(name, namespace string)
IncPipelineROsRunning increments the PipelineRollout counter if it doesn't already know about it
func (*CustomMetrics) SetISBServicesRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) SetISBServicesRolloutHealth(namespace, name, currentPhase string)
SetISBServicesRolloutHealth sets the health of the ISB service rollout
func (*CustomMetrics) SetMonoVerticesRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) SetMonoVerticesRolloutHealth(namespace, name, currentPhase string)
SetMonoVerticesRolloutHealth sets the health of the monovertex rollout
func (*CustomMetrics) SetNumaflowControllerRolloutsHealth ¶ added in v0.13.0
func (m *CustomMetrics) SetNumaflowControllerRolloutsHealth(namespace, name, currentPhase string)
SetNumaflowControllerRolloutsHealth sets the health of the numaflow controller rollout
func (*CustomMetrics) SetNumaflowControllersHealth ¶ added in v0.13.0
func (m *CustomMetrics) SetNumaflowControllersHealth(namespace, name, currentPhase string)
SetNumaflowControllersHealth sets the health of the numaflow controller
func (*CustomMetrics) SetPipelineRolloutHealth ¶ added in v0.13.0
func (m *CustomMetrics) SetPipelineRolloutHealth(namespace, name, currentPhase string)
SetPipelineRolloutHealth sets the health of the pipeline rollout