deltatocumulativeprocessor

package module

v0.131.0 Latest Latest Go to latest Published: Jul 29, 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	@RichieSams, @tombrk

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: <duration> | default = 5m ]
 
        # upper limit of streams to track. new streams exceeding this limit
        # will be dropped
        [ max_streams: <int> | 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 ¶

func NewFactory() processor.Factory
type Config
- func (c Config) Metrics(tel telemetry.Metrics)
- func (c *Config) Validate() error

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

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