util

Documentation

Index

• func GetNodeLister(kubeClient *kube_client.Clientset) (v1listers.NodeLister, *cache.Reflector, error)
• 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, error)
• 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()
• type LabelCopier
  • func NewLabelCopier(separator string, storedLabels, ignoredLabels []string) (*LabelCopier, error)
  • func (this *LabelCopier) Copy(in map[string]string, out map[string]string)

Functions

func GetNodeLister

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

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

LabelCopier maps kubernetes objects' labels to metrics

func NewLabelCopier

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

NewLabelCopier creates a new instance of LabelCopier type

func (*LabelCopier) Copy

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