util

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetNodeLister added in v1.3.0

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

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, error)

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

type LabelCopier added in v1.5.0

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

LabelCopier maps kubernetes objects' labels to metrics

func NewLabelCopier added in v1.5.0

func NewLabelCopier(separator string, storedLabels, ignoredLabels []string) (*LabelCopier, error)

NewLabelCopier creates a new instance of LabelCopier type

func (*LabelCopier) Copy added in v1.5.0

func (this *LabelCopier) Copy(in map[string]string, out map[string]string)

Copy copies the given set of pod labels into a set of metric labels, using the following logic: - all labels, unless found in ignoredLabels, are concatenated into a Separator-seperated key:value pairs and stored under core.LabelLabels.Key - labels found in storedLabels are additionally stored under key provided

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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