util

Documentation

Index

• func CopyLabels(labels map[string]string) map[string]string
• func GetLatest(a, b time.Time) time.Time
• func LabelsToString(labels map[string]string, separator string) string
• type DummyDataProcessor
  • func NewDummyDataProcessor(latency time.Duration) *DummyDataProcessor
  • func (this *DummyDataProcessor) Name() string
  • func (this *DummyDataProcessor) Process(data *core.DataBatch) (*core.DataBatch, error)
• type DummyMetricsSource
  • func NewDummyMetricsSource(name string, latency time.Duration) *DummyMetricsSource
  • func (this *DummyMetricsSource) Name() string
  • func (this *DummyMetricsSource) ScrapeMetrics(start, end time.Time) *core.DataBatch
• type DummyMetricsSourceProvider
  • func NewDummyMetricsSourceProvider(sources ...core.MetricsSource) *DummyMetricsSourceProvider
  • func (this *DummyMetricsSourceProvider) GetMetricsSources() []core.MetricsSource
• type DummySink
  • func NewDummySink(name string, latency time.Duration) *DummySink
  • func (this *DummySink) ExportData(*core.DataBatch)
  • func (this *DummySink) GetExportCount() int
  • func (this *DummySink) IsStopped() bool
  • func (this *DummySink) Name() string
  • func (this *DummySink) Stop()

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()