metrics

Aug 25, 2020

Changes in this version

+ type Collector struct

+ func NewPromCollector(cfg *config.Config) (*Collector, error)

+ func (c *Collector) Collect(ch chan<- prom.Metric)

+ func (c *Collector) Describe(ch chan<- *prom.Desc)

+ func (c *Collector) Duration(node string, executionId string, d float64)

+ func (c *Collector) ExecutionStarted(executionId float64)

+ func (c *Collector) MetricFor(executionID string, node string, name string, result Result)

+ func (c *Collector) Pods(cnt float64)

+ func (c *Collector) ProcessingFinished(node string, executionId string, err bool)

+ func (c *Collector) Prune(executionId string)

+ type Result struct

+ Labels map[string]string

+ Value float64

+ type Results map[string][]Result

+ func (r Results) Validate(cfg *config.Config) error