processors

Documentation

Index

• Variables
• func DuplicateHistogramCounter(name string) gometrics.Counter
• func NewClusterAggregator(metricsToAggregate []string) metrics.Processor
• func NewNamespaceAggregator(metricsToAggregate []string) metrics.Processor
• func NewNodeAggregator(metricsToAggregate []string) metrics.Processor
• type CumulativeDistributionConverter
  • func NewCumulativeDistributionConverter() *CumulativeDistributionConverter
  • func (rc *CumulativeDistributionConverter) Name() string
  • func (rc *CumulativeDistributionConverter) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type DistributionRateCalculator
  • func NewDistributionRateCalculator() *DistributionRateCalculator
  • func (rc *DistributionRateCalculator) Name() string
  • func (rc *DistributionRateCalculator) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type NamespaceBasedEnricher
  • func NewNamespaceBasedEnricher(kubeClient kube_client.Interface) (*NamespaceBasedEnricher, error)
  • func (nbe *NamespaceBasedEnricher) Name() string
  • func (nbe *NamespaceBasedEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type NodeAutoscalingEnricher
  • func NewNodeAutoscalingEnricher(kubeClient kube_client.Interface, labelCopier *util.LabelCopier) (*NodeAutoscalingEnricher, error)
  • func (nae *NodeAutoscalingEnricher) Name() string
  • func (nae *NodeAutoscalingEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type PodAggregator
  • func NewPodAggregator(additionalMetricsToSkip []string) *PodAggregator
  • func (aggregator *PodAggregator) Name() string
  • func (aggregator *PodAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type PodBasedEnricher
  • func NewPodBasedEnricher(podLister v1listers.PodLister, workloadCache util.WorkloadCache, ...) *PodBasedEnricher
  • func (pbe *PodBasedEnricher) Name() string
  • func (pbe *PodBasedEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type PodResourceAggregator
  • func NewPodResourceAggregator(podLister v1listers.PodLister) *PodResourceAggregator
  • func (aggregator *PodResourceAggregator) Name() string
  • func (aggregator *PodResourceAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type RateCalculator
  • func NewRateCalculator(rateMetricsMapping map[string]metrics.Metric) *RateCalculator
  • func (rc *RateCalculator) Name() string
  • func (rc *RateCalculator) Process(batch *metrics.Batch) (*metrics.Batch, error)
• type SumCountAggregateSpec
• type SumCountAggregator
  • func NewSumCountAggregator(name string, specs []SumCountAggregateSpec) *SumCountAggregator
  • func (a *SumCountAggregator) Name() string
  • func (a *SumCountAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)

Variables

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

Functions

func DuplicateHistogramCounter

func DuplicateHistogramCounter(name string) gometrics.Counter

func NewClusterAggregator

func NewClusterAggregator(metricsToAggregate []string) metrics.Processor

func NewNamespaceAggregator

func NewNamespaceAggregator(metricsToAggregate []string) metrics.Processor

func NewNodeAggregator

func NewNodeAggregator(metricsToAggregate []string) metrics.Processor

Types

type CumulativeDistributionConverter

type CumulativeDistributionConverter struct {
}

func NewCumulativeDistributionConverter

func NewCumulativeDistributionConverter() *CumulativeDistributionConverter

func (*CumulativeDistributionConverter) Name

func (rc *CumulativeDistributionConverter) Name() string

func (*CumulativeDistributionConverter) Process

func (rc *CumulativeDistributionConverter) Process(batch *metrics.Batch) (*metrics.Batch, error)

type DistributionRateCalculator

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

func NewDistributionRateCalculator

func NewDistributionRateCalculator() *DistributionRateCalculator

func (*DistributionRateCalculator) Name

func (rc *DistributionRateCalculator) Name() string

func (*DistributionRateCalculator) Process

func (rc *DistributionRateCalculator) Process(batch *metrics.Batch) (*metrics.Batch, error)

type NamespaceBasedEnricher

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

func NewNamespaceBasedEnricher

func NewNamespaceBasedEnricher(kubeClient kube_client.Interface) (*NamespaceBasedEnricher, error)

func (*NamespaceBasedEnricher) Name

func (nbe *NamespaceBasedEnricher) Name() string

func (*NamespaceBasedEnricher) Process

func (nbe *NamespaceBasedEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)

type NodeAutoscalingEnricher

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

func NewNodeAutoscalingEnricher

func NewNodeAutoscalingEnricher(kubeClient kube_client.Interface, labelCopier *util.LabelCopier) (*NodeAutoscalingEnricher, error)

func (*NodeAutoscalingEnricher) Name

func (nae *NodeAutoscalingEnricher) Name() string

func (*NodeAutoscalingEnricher) Process

func (nae *NodeAutoscalingEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)

type PodAggregator

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

func NewPodAggregator

func NewPodAggregator(additionalMetricsToSkip []string) *PodAggregator

func (*PodAggregator) Name

func (aggregator *PodAggregator) Name() string

func (*PodAggregator) Process

func (aggregator *PodAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)

type PodBasedEnricher

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

func NewPodBasedEnricher

func NewPodBasedEnricher(podLister v1listers.PodLister, workloadCache util.WorkloadCache, labelCopier *util.LabelCopier, collectionInterval time.Duration) *PodBasedEnricher

func (*PodBasedEnricher) Name

func (pbe *PodBasedEnricher) Name() string

func (*PodBasedEnricher) Process

func (pbe *PodBasedEnricher) Process(batch *metrics.Batch) (*metrics.Batch, error)

type PodResourceAggregator

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

func NewPodResourceAggregator

func NewPodResourceAggregator(podLister v1listers.PodLister) *PodResourceAggregator

func (*PodResourceAggregator) Name

func (aggregator *PodResourceAggregator) Name() string

func (*PodResourceAggregator) Process

func (aggregator *PodResourceAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)

type RateCalculator

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

func NewRateCalculator

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

func (*RateCalculator) Name

func (rc *RateCalculator) Name() string

func (*RateCalculator) Process

func (rc *RateCalculator) Process(batch *metrics.Batch) (*metrics.Batch, error)

type SumCountAggregateSpec

type SumCountAggregateSpec struct {
	ResourceSumMetrics  []string
	ResourceCountMetric string
	IsPartOfGroup       func(*metrics.Set) bool
	Group               func(batch *metrics.Batch, resourceKey metrics.ResourceKey, resourceSet *metrics.Set) (metrics.ResourceKey, *metrics.Set)
}

type SumCountAggregator

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

func NewSumCountAggregator

func NewSumCountAggregator(name string, specs []SumCountAggregateSpec) *SumCountAggregator

func (*SumCountAggregator) Name

func (a *SumCountAggregator) Name() string

func (*SumCountAggregator) Process

func (a *SumCountAggregator) Process(batch *metrics.Batch) (*metrics.Batch, error)