▽

Package metrics

func Register ¶

func Register(params Params)

type Collector ¶

Collector implements prometheus.Collector interface

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

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
}