observability

Documentation

Index

• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) IncTaskRetry(stage string)
  • func (m *Metrics) IncTaskTotal(stage, result string)
  • func (m *Metrics) ObserveStageDuration(stage string, d time.Duration)
  • func (m *Metrics) RenderPrometheus() string
  • func (m *Metrics) SetWorkerAlive(n int)

Types

type Metrics

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

Metrics stores lightweight Prometheus-compatible runtime metrics.

func NewMetrics

func NewMetrics() *Metrics

func (*Metrics) IncTaskRetry

func (m *Metrics) IncTaskRetry(stage string)

func (*Metrics) IncTaskTotal

func (m *Metrics) IncTaskTotal(stage, result string)

func (*Metrics) ObserveStageDuration

func (m *Metrics) ObserveStageDuration(stage string, d time.Duration)

func (*Metrics) RenderPrometheus

func (m *Metrics) RenderPrometheus() string

func (*Metrics) SetWorkerAlive

func (m *Metrics) SetWorkerAlive(n int)