package util
import "k8s.io/heapster/metrics/util"
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
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 ¶
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 ¶
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 (*DummySink) ExportData ¶
func (*DummySink) GetExportCount ¶
func (*DummySink) IsStopped ¶
func (*DummySink) Name ¶
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
Source Files ¶
dummies.go label_copier.go util.go
Directories ¶
Path | Synopsis |
---|---|
metrics/util/metrics |
- Version
- v1.5.4 (latest)
- Published
- Jul 26, 2018
- Platform
- linux/amd64
- Imports
- 11 packages
- Last checked
- 1 week ago –
Tools for package owners.