metrics

Documentation

Index

• func Register(params Params)
• type Collector
  • func NewCollector(log logr.Logger, experimentStore core.ExperimentStore, ...) *Collector
  • func (collector *Collector) Collect(ch chan<- prometheus.Metric)
  • func (collector *Collector) Describe(ch chan<- *prometheus.Desc)
• type Params

Functions

func Register

func Register(params Params)

Types

type Collector

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

Collector implements prometheus.Collector interface

func NewCollector

func NewCollector(log logr.Logger, experimentStore core.ExperimentStore, scheduleStore core.ScheduleStore, workflowStore core.WorkflowStore) *Collector

NewCollector initializes metrics and collector

func (*Collector) Collect

func (collector *Collector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (*Collector) Describe

func (collector *Collector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.

type Params

type Params struct {
	fx.In
	Log             logr.Logger
	Registry        *prometheus.Registry
	ExperimentStore core.ExperimentStore
	ScheduleStore   core.ScheduleStore
	WorkflowStore   core.WorkflowStore
}