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 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.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package consumerdata contains data structures that holds proto metrics/spans, node and resource.
|
Package consumerdata contains data structures that holds proto metrics/spans, node and resource. |
|
Package consumererror provides wrappers to easily classify errors.
|
Package consumererror provides wrappers to easily classify errors. |
|
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. |
|
Package pdatautil is a temporary package to allow components to transition to the new API.
|
Package pdatautil is a temporary package to allow components to transition to the new API. |