Documentation ¶
Overview ¶
Package consumer contains interfaces that receive and process consumerdata.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Logs ¶ added in v0.23.0
type Logs interface { // ConsumeLogs receives pdata.Logs for consumption. ConsumeLogs(ctx context.Context, ld pdata.Logs) error }
Logs 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 Metrics ¶ added in v0.23.0
type Metrics interface { // ConsumeMetrics receives pdata.Metrics for consumption. ConsumeMetrics(ctx context.Context, md pdata.Metrics) error }
Metrics 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 Traces ¶ added in v0.23.0
type Traces interface { // ConsumeTraces receives pdata.Traces for consumption. ConsumeTraces(ctx context.Context, td pdata.Traces) error }
Traces 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.
Directories ¶
Path | Synopsis |
---|---|
Package consumererror provides wrappers to easily classify errors.
|
Package consumererror provides wrappers to easily classify errors. |
consumererrorprofiles
Module
|
|
xconsumererror
Module
|
|
consumerprofiles
module
|
|
Package fanoutconsumer contains implementations of Traces/Metrics/Logs consumers that fan out the data to multiple other consumers.
|
Package fanoutconsumer contains implementations of Traces/Metrics/Logs consumers that fan out the data to multiple other consumers. |
Package pdata (pipeline data) implements data structures that represent telemetry data in-memory.
|
Package pdata (pipeline data) implements data structures that represent telemetry data in-memory. |
xconsumer
module
|
Click to show internal directories.
Click to hide internal directories.