metrics

Documentation

Index

• type Metrics
  • func NewMetrics(ipPortAddress string, reg prometheus.Registerer, logger logging.Logger) *Metrics
  • func (m *Metrics) IncAggregatedResponses()
  • func (m *Metrics) IncOperatorTaskResponses()
  • func (m *Metrics) Start(ctx context.Context, reg prometheus.Gatherer) <-chan error

Types

type Metrics

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

func NewMetrics

func NewMetrics(ipPortAddress string, reg prometheus.Registerer, logger logging.Logger) *Metrics

func (*Metrics) IncAggregatedResponses

func (m *Metrics) IncAggregatedResponses()

func (*Metrics) IncOperatorTaskResponses

func (m *Metrics) IncOperatorTaskResponses()

func (*Metrics) Start

func (m *Metrics) Start(ctx context.Context, reg prometheus.Gatherer) <-chan error

Start creates a http handler for reg and starts the prometheus server in a goroutine, listening at m.ipPortAddress. reg needs to be the prometheus registry that was passed in the NewMetrics constructor