monitoring

Documentation

Index

• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) Init(isUnitTest bool)
  • func (m *Metrics) RecordEnqueueCnt(target string)
  • func (m *Metrics) RecordEnqueueDur(target string, elapsed float64)
  • func (m *Metrics) RecordErrorCnt(target string)
  • func (m *Metrics) RecordReconciliationCnt(target string)
  • func (m *Metrics) RecordReconciliationDur(target string, elapsed float64)
  • func (m *Metrics) RecordRequeueCnt(target string)
• type MetricsI

Types

type Metrics

type Metrics struct {
	RequeueCnt        *prometheus.CounterVec
	ReconciliationCnt *prometheus.CounterVec
	ReconciliationDur *prometheus.HistogramVec
	EnqueueCnt        *prometheus.CounterVec
	EnqueueDur        *prometheus.HistogramVec
	ErrCnt            *prometheus.CounterVec
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics() *Metrics

func (*Metrics) Init

func (m *Metrics) Init(isUnitTest bool)

func (*Metrics) RecordEnqueueCnt

func (m *Metrics) RecordEnqueueCnt(target string)

func (*Metrics) RecordEnqueueDur

func (m *Metrics) RecordEnqueueDur(target string, elapsed float64)

func (*Metrics) RecordErrorCnt

func (m *Metrics) RecordErrorCnt(target string)

func (*Metrics) RecordReconciliationCnt

func (m *Metrics) RecordReconciliationCnt(target string)

func (*Metrics) RecordReconciliationDur

func (m *Metrics) RecordReconciliationDur(target string, elapsed float64)

func (*Metrics) RecordRequeueCnt

func (m *Metrics) RecordRequeueCnt(target string)

type MetricsI

type MetricsI interface {
	RecordRequeueCnt(target string)
	RecordReconciliationCnt(target string)
	RecordReconciliationDur(target string, elapsed float64)
	RecordEnqueueCnt(target string)
	RecordEnqueueDur(target string, elapsed float64)
	RecordErrorCnt(target string)
}