cumulativetodelta

Documentation

Overview

Package cumulativetodelta provides an otelcol.processor.cumulativetodelta component.

Index

• Constants
• Variables
• func ConvertInitialValue(initialValue string) (map[string]interface{}, error)
• type Arguments
  • func (args Arguments) Convert() (otelcomponent.Config, error)
  • func (args Arguments) DebugMetricsConfig() otelcolCfg.DebugMetricsArguments
  • func (args Arguments) Exporters() map[pipeline.Signal]map[otelcomponent.ID]otelcomponent.Component
  • func (args Arguments) Extensions() map[otelcomponent.ID]otelcomponent.Component
  • func (args Arguments) NextConsumers() *otelcol.ConsumerArguments
  • func (args *Arguments) SetToDefault()
  • func (args *Arguments) Validate() error
• type MatchArgs
  • func (matchArgs MatchArgs) Convert() (*cumulativetodeltaprocessor.MatchMetrics, error)

Constants

const (
	InitialValueAuto string = "auto"
	InitialValueKeep string = "keep"
	InitialValueDrop string = "drop"
)

Variables

var DefaultArguments = Arguments{
	Include:      MatchArgs{},
	Exclude:      MatchArgs{},
	MaxStaleness: 0,
	InitialValue: "auto",
}

DefaultArguments holds default settings for Arguments.

Functions

func ConvertInitialValue

func ConvertInitialValue(initialValue string) (map[string]interface{}, error)

Types

type Arguments

type Arguments struct {
	MaxStaleness time.Duration `alloy:"max_staleness,attr,optional"`
	InitialValue string        `alloy:"initial_value,attr,optional"`
	Include      MatchArgs     `alloy:"include,block,optional"`
	Exclude      MatchArgs     `alloy:"exclude,block,optional"`

	// Output configures where to send processed data. Required.
	Output *otelcol.ConsumerArguments `alloy:"output,block"`

	// DebugMetrics configures component internal metrics. Optional.
	DebugMetrics otelcolCfg.DebugMetricsArguments `alloy:"debug_metrics,block,optional"`
}

Arguments configures the otelcol.processor.cumulativetodelta component.

func (Arguments) Convert

func (args Arguments) Convert() (otelcomponent.Config, error)

Convert implements processor.Arguments.

func (Arguments) DebugMetricsConfig

func (args Arguments) DebugMetricsConfig() otelcolCfg.DebugMetricsArguments

DebugMetricsConfig implements processor.Arguments.

func (Arguments) Exporters

func (args Arguments) Exporters() map[pipeline.Signal]map[otelcomponent.ID]otelcomponent.Component

Exporters implements processor.Arguments.

func (Arguments) Extensions

func (args Arguments) Extensions() map[otelcomponent.ID]otelcomponent.Component

Extensions implements processor.Arguments.

func (Arguments) NextConsumers

func (args Arguments) NextConsumers() *otelcol.ConsumerArguments

NextConsumers implements processor.Arguments.

func (*Arguments) SetToDefault

func (args *Arguments) SetToDefault()

SetToDefault implements syntax.Defaulter.

func (*Arguments) Validate

func (args *Arguments) Validate() error

Validate implements syntax.Validator.

type MatchArgs

type MatchArgs struct {
	Metrics     []string `alloy:"metrics,attr,optional"`
	MatchType   string   `alloy:"match_type,attr,optional"`
	MetricTypes []string `alloy:"metric_types,attr,optional"`
}

func (MatchArgs) Convert

func (matchArgs MatchArgs) Convert() (*cumulativetodeltaprocessor.MatchMetrics, error)