consumer

Documentation

Overview

Package consumer contains interfaces that receive and process consumerdata.

Index

• type LogConsumer
• type MetricsConsumer
• type MetricsConsumerBase
• type MetricsConsumerOld
• type TraceConsumer
• type TraceConsumerBase
• type TraceConsumerOld

Types

type LogConsumer

type LogConsumer interface {
	// ConsumeLogs receives data.Logs for processing.
	ConsumeLogs(ctx context.Context, ld data.Logs) error
}

LogConsumer is an interface that receives data.Logs, processes it as needed, and sends it to the next processing node if any or to the destination.

type MetricsConsumer

type MetricsConsumer interface {
	MetricsConsumerBase
	ConsumeMetrics(ctx context.Context, md pdata.Metrics) error
}

MetricsConsumer is the new metrics consumer interface that receives pdata.MetricData, processes it as needed, and sends it to the next processing node if any or to the destination.

type MetricsConsumerBase

type MetricsConsumerBase interface{}

MetricsConsumerBase defines a common interface for MetricsConsumerOld and MetricsConsumer.

type MetricsConsumerOld

type MetricsConsumerOld interface {
	MetricsConsumerBase
	ConsumeMetricsData(ctx context.Context, md consumerdata.MetricsData) error
}

MetricsConsumerOld is an interface that receives consumerdata.MetricsData, process it as needed, and sends it to the next processing node if any or to the destination.

ConsumeMetricsData receives consumerdata.MetricsData for processing by the MetricsConsumer.

type TraceConsumer

type TraceConsumer interface {
	TraceConsumerBase
	// ConsumeTraces receives pdata.Traces for processing.
	ConsumeTraces(ctx context.Context, td pdata.Traces) error
}

TraceConsumer is an interface that receives pdata.Traces, processes it as needed, and sends it to the next processing node if any or to the destination.

type TraceConsumerBase

type TraceConsumerBase interface{}

TraceConsumerBase defines a common interface for TraceConsumerOld and TraceConsumer.

type TraceConsumerOld

type TraceConsumerOld interface {
	TraceConsumerBase
	ConsumeTraceData(ctx context.Context, td consumerdata.TraceData) error
}

TraceConsumerOld is an interface that receives consumerdata.TraceData, process it as needed, and sends it to the next processing node if any or to the destination.

ConsumeTraceData receives consumerdata.TraceData for processing by the TraceConsumer.