util

package
Version: v0.20.0-alpha11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2016 License: Apache-2.0 Imports: 6 Imported by: 36

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CopyLabels

func CopyLabels(labels map[string]string) map[string]string

func GetLatest

func GetLatest(a, b time.Time) time.Time

func LabelsToString

func LabelsToString(labels map[string]string, separator string) string

Concatenates a map of labels into a comma-separated key=value pairs.

Types

type DummyDataProcessor

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

func NewDummyDataProcessor

func NewDummyDataProcessor(latency time.Duration) *DummyDataProcessor

func (*DummyDataProcessor) Name

func (this *DummyDataProcessor) Name() string

func (*DummyDataProcessor) Process

func (this *DummyDataProcessor) Process(data *core.DataBatch) (*core.DataBatch, error)

type DummyMetricsSource

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

func NewDummyMetricsSource

func NewDummyMetricsSource(name string, latency time.Duration) *DummyMetricsSource

func (*DummyMetricsSource) Name

func (this *DummyMetricsSource) Name() string

func (*DummyMetricsSource) ScrapeMetrics

func (this *DummyMetricsSource) ScrapeMetrics(start, end time.Time) *core.DataBatch

type DummyMetricsSourceProvider

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

func NewDummyMetricsSourceProvider

func NewDummyMetricsSourceProvider(sources ...core.MetricsSource) *DummyMetricsSourceProvider

func (*DummyMetricsSourceProvider) GetMetricsSources

func (this *DummyMetricsSourceProvider) GetMetricsSources() []core.MetricsSource

type DummySink

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

func NewDummySink

func NewDummySink(name string, latency time.Duration) *DummySink

func (*DummySink) ExportData

func (this *DummySink) ExportData(*core.DataBatch)

func (*DummySink) GetExportCount

func (this *DummySink) GetExportCount() int

func (*DummySink) IsStopped

func (this *DummySink) IsStopped() bool

func (*DummySink) Name

func (this *DummySink) Name() string

func (*DummySink) Stop

func (this *DummySink) Stop()

Source Files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL