processors

package
v0.0.0-...-1d907cd Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)

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.