processortest

Documentation

Index

• func NewNopMetricsProcessor(nextMetricsProcessor consumer.MetricsConsumerOld) consumer.MetricsConsumerOld
• func NewNopTraceProcessor(nextTraceProcessor consumer.TraceConsumerOld) consumer.TraceConsumerOld
• type NopProcessorFactory
  • func (npf *NopProcessorFactory) CreateDefaultConfig() configmodels.Processor
  • func (npf *NopProcessorFactory) CreateMetricsProcessor(logger *zap.Logger, nextConsumer consumer.MetricsConsumerOld, ...) (component.MetricsProcessorOld, error)
  • func (npf *NopProcessorFactory) CreateTraceProcessor(logger *zap.Logger, nextConsumer consumer.TraceConsumerOld, ...) (component.TraceProcessorOld, error)
  • func (npf *NopProcessorFactory) Type() configmodels.Type

Functions

func NewNopMetricsProcessor

func NewNopMetricsProcessor(nextMetricsProcessor consumer.MetricsConsumerOld) consumer.MetricsConsumerOld

NewNopMetricsProcessor creates an MetricsProcessor that just pass the received data to the nextMetricsProcessor.

func NewNopTraceProcessor

func NewNopTraceProcessor(nextTraceProcessor consumer.TraceConsumerOld) consumer.TraceConsumerOld

NewNopTraceProcessor creates an TraceProcessor that just pass the received data to the nextTraceProcessor.

Types

type NopProcessorFactory

type NopProcessorFactory struct{}

NopProcessorFactory allows the creation of the no operation processor via config, so it can be used in tests that cannot create it directly.

func (*NopProcessorFactory) CreateDefaultConfig

func (npf *NopProcessorFactory) CreateDefaultConfig() configmodels.Processor

CreateDefaultConfig creates the default configuration for the Processor.

func (*NopProcessorFactory) CreateMetricsProcessor

func (npf *NopProcessorFactory) CreateMetricsProcessor(
	logger *zap.Logger,
	nextConsumer consumer.MetricsConsumerOld,
	cfg configmodels.Processor,
) (component.MetricsProcessorOld, error)

CreateMetricsProcessor creates a metrics processor based on this config. If the processor type does not support metrics or if the config is not valid error will be returned instead.

func (*NopProcessorFactory) CreateTraceProcessor

func (npf *NopProcessorFactory) CreateTraceProcessor(
	logger *zap.Logger,
	nextConsumer consumer.TraceConsumerOld,
	cfg configmodels.Processor,
) (component.TraceProcessorOld, error)

CreateTraceProcessor creates a trace processor based on this config. If the processor type does not support tracing or if the config is not valid error will be returned instead.

func (*NopProcessorFactory) Type

func (npf *NopProcessorFactory) Type() configmodels.Type

Type gets the type of the Processor created by this factory.