util

package
v0.0.0-...-2a78edc Latest Latest
Warning

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

Go to latest
Published: Jan 11, 2020 License: Apache-2.0, Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetNodeLister

func GetNodeLister(kubeClient *kube_client.Clientset) (v1listers.NodeLister, *cache.Reflector, error)

func LabelsToString

func LabelsToString(labels map[string]string) string

Concatenates a map of labels into a Seperator-seperated key:value pairs.

func SetLabelSeperator

func SetLabelSeperator(seperator string)

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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