probabilistic_sampler

Documentation

Overview

Package probabilistic_sampler provides an otelcol.processor.probabilistic_sampler component.

Index

• Variables
• 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]otelextension.Extension
  • func (args Arguments) NextConsumers() *otelcol.ConsumerArguments
  • func (args *Arguments) SetToDefault()
  • func (args *Arguments) Validate() error

Variables

var DefaultArguments = Arguments{
	FailClosed:        true,
	AttributeSource:   "traceID",
	SamplingPrecision: 4,
}

DefaultArguments holds default settings for Arguments.

Types

type Arguments

type Arguments struct {
	SamplingPercentage float32 `alloy:"sampling_percentage,attr,optional"`
	HashSeed           uint32  `alloy:"hash_seed,attr,optional"`
	Mode               string  `alloy:"mode,attr,optional"`
	FailClosed         bool    `alloy:"fail_closed,attr,optional"`
	SamplingPrecision  int     `alloy:"sampling_precision,attr,optional"`
	AttributeSource    string  `alloy:"attribute_source,attr,optional"`
	FromAttribute      string  `alloy:"from_attribute,attr,optional"`
	SamplingPriority   string  `alloy:"sampling_priority,attr,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.probabilistic_sampler 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]otelextension.Extension

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.