metrics

Documentation

Index

• type CustomMetrics
  • func RegisterCustomMetrics() *CustomMetrics
  • func (m *CustomMetrics) DecISBServiceMetrics(name, namespace string)
  • func (m *CustomMetrics) DecNumaflowControllerMetrics(name, namespace, version string)
  • func (m *CustomMetrics) DecPipelineMetrics(name, namespace string)
  • func (m *CustomMetrics) GetISBServiceCounterMap() map[string]struct{}
  • func (m *CustomMetrics) GetPipelineCounterMap() map[string]struct{}
  • func (m *CustomMetrics) IncISBServiceMetrics(name, namespace string)
  • func (m *CustomMetrics) IncNumaflowControllerMetrics(name, namespace, version string)
  • func (m *CustomMetrics) IncPipelineMetrics(name, namespace string)

Types

type CustomMetrics

type CustomMetrics struct {
	// contains filtered or unexported fields
}

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) DecISBServiceMetrics

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

DecISBServiceMetrics decrements the ISBService counter

func (*CustomMetrics) DecNumaflowControllerMetrics

func (m *CustomMetrics) DecNumaflowControllerMetrics(name, namespace, version string)

DecNumaflowControllerMetrics decrements the Numaflow Controller counter

func (*CustomMetrics) DecPipelineMetrics

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

DecPipelineMetrics decrements the pipeline counter

func (*CustomMetrics) GetISBServiceCounterMap

func (m *CustomMetrics) GetISBServiceCounterMap() map[string]struct{}

GetISBServiceCounterMap returns the ISBService counter

func (*CustomMetrics) GetPipelineCounterMap

func (m *CustomMetrics) GetPipelineCounterMap() map[string]struct{}

GetPipelineCounterMap returns the pipeline counter

func (*CustomMetrics) IncISBServiceMetrics

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

IncISBServiceMetrics increments the ISBService counter if it doesn't already know about the ISBService

func (*CustomMetrics) IncNumaflowControllerMetrics

func (m *CustomMetrics) IncNumaflowControllerMetrics(name, namespace, version string)

IncNumaflowControllerMetrics increments the Numaflow Controller counter if it doesn't already know about the Numaflow Controller

func (*CustomMetrics) IncPipelineMetrics

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

IncPipelineMetrics increments the pipeline counter if it doesn't already know about the pipeline