metrics

Documentation

Index

• type Collector
  • 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
• type Results
  • func (r Results) Validate(cfg *config.Config) error

Types

type Collector

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

Collector struct

func NewPromCollector

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

NewPromCollector create a new prom collector

func (*Collector) Collect

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

Collect returns the current state of the metrics

func (*Collector) Describe

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

Describe returns all the descriptions of the collector

func (*Collector) Duration

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

Duration record duration

func (*Collector) ExecutionStarted

func (c *Collector) ExecutionStarted(executionId float64)

ExecutionStarted metric for new executions

func (*Collector) MetricFor

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

MetricFor record metrics for the given result

func (*Collector) Pods

func (c *Collector) Pods(cnt float64)

Pods record the number of pods started for the current run

func (*Collector) ProcessingFinished

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

ProcessingFinished record proceiing finished

func (*Collector) Prune

func (c *Collector) Prune(executionId string)

Prune metrics assigned to the given execution ID

type Result

type Result struct {
	Value  float64           `json:"value"`
	Labels map[string]string `json:"labels"`
}

Result metrics result

type Results

type Results map[string][]Result

Results map of results

func (Results) Validate

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

Validate the results