testutils

Documentation

Overview

Package testutils provides utilities for tests.

Index

• func EventMetricsByTargetMetric(ems []*metrics.EventMetrics) map[string]map[string][]*metrics.EventMetrics
• func LabelsMapByTarget(ems []*metrics.EventMetrics) map[string]map[string]string
• func MetricsFromChannel(dataChan chan *metrics.EventMetrics, num int, timeout time.Duration) (results []*metrics.EventMetrics, err error)
• type MetricsMap
  • func MetricsMapByTarget(ems []*metrics.EventMetrics) MetricsMap
  • func (mmap MetricsMap) Filter(metricName string) map[string][]metrics.Value
  • func (mmap MetricsMap) LastValueInt64(target, metricName string) int64

Functions

func EventMetricsByTargetMetric

func EventMetricsByTargetMetric(ems []*metrics.EventMetrics) map[string]map[string][]*metrics.EventMetrics

func LabelsMapByTarget

func LabelsMapByTarget(ems []*metrics.EventMetrics) map[string]map[string]string

func MetricsFromChannel

func MetricsFromChannel(dataChan chan *metrics.EventMetrics, num int, timeout time.Duration) (results []*metrics.EventMetrics, err error)

MetricsFromChannel reads metrics.EventMetrics from dataChannel with a timeout

Types

type MetricsMap

type MetricsMap map[string]map[string][]metrics.Value

func MetricsMapByTarget

func MetricsMapByTarget(ems []*metrics.EventMetrics) MetricsMap

MetricsMapByTarget rearranges a list of metrics into a map of map.

{
  "target1": {
      "m1": [val1, val2..],
      "m2": [val1],
  },
  "target2": {
      ...
  }
}

func (MetricsMap) Filter

func (mmap MetricsMap) Filter(metricName string) map[string][]metrics.Value

Filter returns a map of target to values for a given metric name.

func (MetricsMap) LastValueInt64

func (mmap MetricsMap) LastValueInt64(target, metricName string) int64

LastValueInt64 returns the last value for a given metric name and target.