metrics

Documentation

Index

• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) ActionDuration(sensorName, triggerName string, num float64)
  • func (m *Metrics) ActionFailed(sensorName, triggerName string)
  • func (m *Metrics) ActionTriggered(sensorName, triggerName string)
  • func (m *Metrics) Collect(ch chan<- prometheus.Metric)
  • func (m *Metrics) DecRunningServices(eventSourceName string)
  • func (m *Metrics) Describe(ch chan<- *prometheus.Desc)
  • func (m *Metrics) EventProcessingDuration(eventSourceName, eventName string, num float64)
  • func (m *Metrics) EventProcessingFailed(eventSourceName, eventName string)
  • func (m *Metrics) EventSent(eventSourceName, eventName string)
  • func (m *Metrics) EventSentFailed(eventSourceName, eventName string)
  • func (m *Metrics) IncRunningServices(eventSourceName string)
  • func (m *Metrics) Run(ctx context.Context, addr string)

Types

type Metrics

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

Metrics represents EventSource metrics information

func NewMetrics

func NewMetrics(namespace string) *Metrics

NewMetrics returns a Metrics instance

func (*Metrics) ActionDuration

func (m *Metrics) ActionDuration(sensorName, triggerName string, num float64)

func (*Metrics) ActionFailed

func (m *Metrics) ActionFailed(sensorName, triggerName string)

func (*Metrics) ActionTriggered

func (m *Metrics) ActionTriggered(sensorName, triggerName string)

func (*Metrics) Collect

func (m *Metrics) Collect(ch chan<- prometheus.Metric)

func (*Metrics) DecRunningServices

func (m *Metrics) DecRunningServices(eventSourceName string)

func (*Metrics) Describe

func (m *Metrics) Describe(ch chan<- *prometheus.Desc)

func (*Metrics) EventProcessingDuration

func (m *Metrics) EventProcessingDuration(eventSourceName, eventName string, num float64)

func (*Metrics) EventProcessingFailed

func (m *Metrics) EventProcessingFailed(eventSourceName, eventName string)

func (*Metrics) EventSent

func (m *Metrics) EventSent(eventSourceName, eventName string)

func (*Metrics) EventSentFailed

func (m *Metrics) EventSentFailed(eventSourceName, eventName string)

func (*Metrics) IncRunningServices

func (m *Metrics) IncRunningServices(eventSourceName string)

func (*Metrics) Run

func (m *Metrics) Run(ctx context.Context, addr string)

Run starts a metrics server