metricsink

Documentation

Index

• type MetricSink
  • func NewMetricSink(shortStoreDuration, longStoreDuration time.Duration, longStoreMetrics []string) *MetricSink
  • func (this *MetricSink) ExportData(batch *core.DataBatch)
  • func (this *MetricSink) GetContainersForPodFromNamespace(namespace, pod string) []string
  • func (this *MetricSink) GetLabeledMetric(metricName string, labels map[string]string, keys []string, ...) map[string][]core.TimestampedMetricValue
  • func (this *MetricSink) GetLatestDataBatch() *core.DataBatch
  • func (this *MetricSink) GetMetric(metricName string, keys []string, start, end time.Time) map[string][]core.TimestampedMetricValue
  • func (this *MetricSink) GetMetricNames(key string) []string
  • func (this *MetricSink) GetMetricSetKeys() []string
  • func (this *MetricSink) GetNamespaces() []string
  • func (this *MetricSink) GetNodes() []string
  • func (this *MetricSink) GetPods() []string
  • func (this *MetricSink) GetPodsFromNamespace(namespace string) []string
  • func (this *MetricSink) GetShortStore() []*core.DataBatch
  • func (this *MetricSink) GetSystemContainersFromNode(node string) []string
  • func (this *MetricSink) Name() string
  • func (this *MetricSink) Stop()

Types

type MetricSink

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

A simple in-memory storage for metrics. It divides metrics into 2 categories * metrics that need to be stored for couple minutes. * metrics that need to be stored for longer time (15 min, 1 hour). The user of this struct needs to decide what are the long-stored metrics uprfront.

func NewMetricSink

func NewMetricSink(shortStoreDuration, longStoreDuration time.Duration, longStoreMetrics []string) *MetricSink

func (*MetricSink) ExportData

func (this *MetricSink) ExportData(batch *core.DataBatch)

func (*MetricSink) GetContainersForPodFromNamespace

func (this *MetricSink) GetContainersForPodFromNamespace(namespace, pod string) []string

func (*MetricSink) GetLabeledMetric

func (this *MetricSink) GetLabeledMetric(metricName string, labels map[string]string, keys []string, start, end time.Time) map[string][]core.TimestampedMetricValue

func (*MetricSink) GetLatestDataBatch

func (this *MetricSink) GetLatestDataBatch() *core.DataBatch

func (*MetricSink) GetMetric

func (this *MetricSink) GetMetric(metricName string, keys []string, start, end time.Time) map[string][]core.TimestampedMetricValue

func (*MetricSink) GetMetricNames

func (this *MetricSink) GetMetricNames(key string) []string

func (*MetricSink) GetMetricSetKeys

func (this *MetricSink) GetMetricSetKeys() []string

* For debugging only.

func (*MetricSink) GetNamespaces

func (this *MetricSink) GetNamespaces() []string

func (*MetricSink) GetNodes

func (this *MetricSink) GetNodes() []string

func (*MetricSink) GetPods

func (this *MetricSink) GetPods() []string

func (*MetricSink) GetPodsFromNamespace

func (this *MetricSink) GetPodsFromNamespace(namespace string) []string

func (*MetricSink) GetShortStore

func (this *MetricSink) GetShortStore() []*core.DataBatch

func (*MetricSink) GetSystemContainersFromNode

func (this *MetricSink) GetSystemContainersFromNode(node string) []string

func (*MetricSink) Name

func (this *MetricSink) Name() string

func (*MetricSink) Stop

func (this *MetricSink) Stop()