processors

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.