package processors

import "k8s.io/heapster/metrics/processors"

Index ¶

• Variables
• type ClusterAggregator
• func (this *ClusterAggregator) Name() string
• func (this *ClusterAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type NamespaceAggregator
• func (this *NamespaceAggregator) Name() string
• func (this *NamespaceAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type NamespaceBasedEnricher
• func NewNamespaceBasedEnricher(url *url.URL) (*NamespaceBasedEnricher, error)
• func (this *NamespaceBasedEnricher) Name() string
• func (this *NamespaceBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type NodeAggregator
• func (this *NodeAggregator) Name() string
• func (this *NodeAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type NodeAutoscalingEnricher
• func NewNodeAutoscalingEnricher(url *url.URL, labelCopier *util.LabelCopier) (*NodeAutoscalingEnricher, error)
• func (this *NodeAutoscalingEnricher) Name() string
• func (this *NodeAutoscalingEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type PodAggregator
• func NewPodAggregator() *PodAggregator
• func (this *PodAggregator) Name() string
• func (this *PodAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type PodBasedEnricher
• func NewPodBasedEnricher(podLister v1listers.PodLister, labelCopier *util.LabelCopier) (*PodBasedEnricher, error)
• func (this *PodBasedEnricher) Name() string
• func (this *PodBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)
• type RateCalculator
• func NewRateCalculator(metrics map[string]core.Metric) *RateCalculator
• func (this *RateCalculator) Name() string
• func (this *RateCalculator) Process(batch *core.DataBatch) (*core.DataBatch, error)

Variables ¶

var LabelsToPopulate = []core.LabelDescriptor{
	core.LabelPodId,
	core.LabelPodName,
	core.LabelNamespaceName,
	core.LabelPodNamespaceUID,
	core.LabelHostname,
	core.LabelHostID,
}

Types ¶

type ClusterAggregator ¶

type ClusterAggregator struct {
	MetricsToAggregate []string
}

func (*ClusterAggregator) Name ¶

func (this *ClusterAggregator) Name() string

func (*ClusterAggregator) Process ¶

func (this *ClusterAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NamespaceAggregator ¶

type NamespaceAggregator struct {
	MetricsToAggregate []string
}

func (*NamespaceAggregator) Name ¶

func (this *NamespaceAggregator) Name() string

func (*NamespaceAggregator) Process ¶

func (this *NamespaceAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NamespaceBasedEnricher ¶

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

func NewNamespaceBasedEnricher ¶

func NewNamespaceBasedEnricher(url *url.URL) (*NamespaceBasedEnricher, error)

func (*NamespaceBasedEnricher) Name ¶

func (this *NamespaceBasedEnricher) Name() string

func (*NamespaceBasedEnricher) Process ¶

func (this *NamespaceBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NodeAggregator ¶

type NodeAggregator struct {
	MetricsToAggregate []string
}

Does not add any nodes.

func (*NodeAggregator) Name ¶

func (this *NodeAggregator) Name() string

func (*NodeAggregator) Process ¶

func (this *NodeAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NodeAutoscalingEnricher ¶

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

func NewNodeAutoscalingEnricher ¶

func NewNodeAutoscalingEnricher(url *url.URL, labelCopier *util.LabelCopier) (*NodeAutoscalingEnricher, error)

func (*NodeAutoscalingEnricher) Name ¶

func (this *NodeAutoscalingEnricher) Name() string

func (*NodeAutoscalingEnricher) Process ¶

func (this *NodeAutoscalingEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)

type PodAggregator ¶

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

func NewPodAggregator ¶

func NewPodAggregator() *PodAggregator

func (*PodAggregator) Name ¶

func (this *PodAggregator) Name() string

func (*PodAggregator) Process ¶

func (this *PodAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type PodBasedEnricher ¶

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

func NewPodBasedEnricher ¶

func NewPodBasedEnricher(podLister v1listers.PodLister, labelCopier *util.LabelCopier) (*PodBasedEnricher, error)

func (*PodBasedEnricher) Name ¶

func (this *PodBasedEnricher) Name() string

func (*PodBasedEnricher) Process ¶

func (this *PodBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)

type RateCalculator ¶

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

func NewRateCalculator ¶

func NewRateCalculator(metrics map[string]core.Metric) *RateCalculator

func (*RateCalculator) Name ¶

func (this *RateCalculator) Name() string

func (*RateCalculator) Process ¶

func (this *RateCalculator) Process(batch *core.DataBatch) (*core.DataBatch, error)

Source Files ¶

cluster_aggregator.go helper.go namespace_aggregator.go namespace_based_enricher.go node_aggregator.go node_autoscaling_enricher.go pod_aggregator.go pod_based_enricher.go rate_calculator.go