processors

package
v0.0.0-...-e6dca25 Latest Latest
Warning

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

Go to latest
Published: Jan 1, 2022 License: Apache-2.0, Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Jump to

Keyboard shortcuts

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