monitoring

Documentation

Index

• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) GetMetricByName(name string) prometheus.Collector
  • func (m *Metrics) Init(isUnitTest bool)
  • func (m *Metrics) RecordDMSLastTimestamp()
  • func (m *Metrics) RecordEgressRequestCnt(target string)
  • func (m *Metrics) RecordEgressRequestDur(target string, elapsed float64)
• type MetricsI

Types

type Metrics

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

Metrics contains the metrics gathered by the instance and its path

func NewMetrics

func NewMetrics() *Metrics

NewMetrics func

func (*Metrics) GetMetricByName

func (m *Metrics) GetMetricByName(name string) prometheus.Collector

GetMetricByName returns a metric by it's fully qualified name (used for testing purposes)

func (*Metrics) Init

func (m *Metrics) Init(isUnitTest bool)

Init func

func (*Metrics) RecordDMSLastTimestamp

func (m *Metrics) RecordDMSLastTimestamp()

RecordDMSLastTimestamp records the current timestamp when a DMS is received

func (*Metrics) RecordEgressRequestCnt

func (m *Metrics) RecordEgressRequestCnt(target string)

RecordEgressRequestCnt increases the Egress counter for a taget

func (*Metrics) RecordEgressRequestDur

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

RecordEgressRequestDur registers the Egress duration for a taget

type MetricsI

type MetricsI interface {
	RecordEgressRequestCnt(target string)
	RecordEgressRequestDur(target string, elapsed float64)
	RecordDMSLastTimestamp()
	GetMetricByName(name string) prometheus.Collector
}

MetricsI interface