consumer

Documentation

Overview

Package consumer contains interfaces that receive and process consumerdata.

Index

• type LogsConsumer
• type MetricsConsumer
• type TracesConsumer

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.Metrics, processes it as needed, and sends it to the next processing node if any or to the destination.

type TracesConsumer

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

TracesConsumer 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.