processors

Documentation

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)