consumer

Documentation

Overview

Package consumer contains interfaces that receive and process consumerdata.

Index

• type LogsConsumer
• type MetricsConsumer
• type TraceConsumer

Types

type LogsConsumer

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

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

type MetricsConsumer

type MetricsConsumer interface {
	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 TraceConsumer

type TraceConsumer interface {
	// 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.