queuedprocessor

README

Queued Retry Processor

QueuedRetry processor is deprecated. Use exporter queued retry config.

Documentation

Index

• func MetricViews(level configtelemetry.Level) []*view.View
• func NewFactory() component.ProcessorFactory
• type Config

Functions

func MetricViews

func MetricViews(level configtelemetry.Level) []*view.View

MetricViews return the metrics views according to given telemetry level.

func NewFactory

func NewFactory() component.ProcessorFactory

NewFactory returns a new factory for the Queued processor.

Types

type Config

type Config struct {
	configmodels.ProcessorSettings `mapstructure:",squash"`

	// NumConsumers is the number of queue workers that dequeue batches and send them out.
	NumWorkers int `mapstructure:"num_workers"`
	// QueueSize is the maximum number of batches allowed in queue at a given time.
	QueueSize int `mapstructure:"queue_size"`
	// Retry indicates whether queue processor should retry span batches in case of processing failure.
	RetryOnFailure bool `mapstructure:"retry_on_failure"`
	// BackoffDelay is the amount of time a worker waits after a failed send before retrying.
	BackoffDelay time.Duration `mapstructure:"backoff_delay"`
}

Config defines configuration for Attributes processor.