deltatocumulativeprocessor

package module

v0.128.0 Latest Latest Go to latest Published: Jun 9, 2025 License: Apache-2.0 Imports: 19 Imported by: 4

README ¶

Delta to cumulative processor

Status
Stability	alpha: metrics
Distributions	contrib, k8s
Warnings	Statefulness
Issues
Code coverage
Code Owners	@sh0rez, @RichieSams

Description

The delta to cumulative processor (deltatocumulativeprocessor) converts metrics from delta temporality to cumulative, by accumulating samples in memory.

Configuration

processors:
    deltatocumulative:
        # how long until a series not receiving new samples is removed
        [ max_stale:  | default = 5m ]
 
        # upper limit of streams to track. new streams exceeding this limit
        # will be dropped
        [ max_streams:  | default = 9223372036854775807 (max int) ]

There is no further configuration required. All delta samples are converted to cumulative.

Troubleshooting

When Telemetry is enabled, this component exports several metrics.

Documentation ¶

Overview ¶

package deltatocumulativeprocessor implements a processor which converts metrics from delta temporality to cumulative.

Index ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewFactory ¶

func NewFactory() processor.Factory

Types ¶

type Config ¶

type Config struct {
	MaxStale   time.Duration `mapstructure:"max_stale"`
	MaxStreams int           `mapstructure:"max_streams"`
}

func (Config) Metrics ¶ added in v0.111.0

func (c Config) Metrics(tel telemetry.Metrics)

func (*Config) Validate ¶

func (c *Config) Validate() error

type Processor ¶

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

func (*Processor) Capabilities ¶

func (p *Processor) Capabilities() consumer.Capabilities

func (*Processor) ConsumeMetrics ¶

func (p *Processor) ConsumeMetrics(ctx context.Context, md pmetric.Metrics) error

func (*Processor) Shutdown ¶

func (p *Processor) Shutdown(_ context.Context) error

func (*Processor) Start ¶

func (p *Processor) Start(_ context.Context, _ component.Host) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
internal
data
data/datatest
data/expo Package expo implements various operations on exponential histograms and their bucket counts	Package expo implements various operations on exponential histograms and their bucket counts
data/expo/expotest
data/histo
data/histo/histotest
delta
maps
metadata
metadatatest
metrics
putil/pslice
telemetry
testing/compare
testing/sdktest sdktest performs partial comparison of sdk.ResourceMetrics to a Spec.	sdktest performs partial comparison of sdk.ResourceMetrics to a Spec.
testing/testar testar is a textual archive (based on golang.org/x/tools/txtar) to define test fixtures.	testar is a textual archive (based on golang.org/x/tools/txtar) to define test fixtures.
testing/testar/crlf

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