Documentation
¶
Overview ¶
Package consumer contains interfaces that receive and process consumerdata.
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 MetricsConsumer ¶
type MetricsConsumer interface {
MetricsConsumerBase
ConsumeMetrics(ctx context.Context, md data.MetricData) error
}
MetricsConsumer is the new metrics consumer interface that receives data.MetricData, processes it as needed, and sends it to the next processing node if any or to the destination.
func NewInternalToOCMetricsConverter ¶ added in v0.2.8
func NewInternalToOCMetricsConverter(tc MetricsConsumerOld) MetricsConsumer
NewInternalToOCMetricsConverter creates new internalToOCMetricsConverter that takes MetricsConsumer and implements ConsumeTrace interface.
type MetricsConsumerBase ¶ added in v0.2.9
type MetricsConsumerBase interface{}
MetricsConsumerBase defines a common interface for MetricsConsumerOld and MetricsConsumer.
type MetricsConsumerOld ¶ added in v0.2.8
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
// ConsumeTrace receives data.TraceData for processing.
ConsumeTrace(ctx context.Context, td data.TraceData) error
}
TraceConsumer is an interface that receives data.TraceData, processes it as needed, and sends it to the next processing node if any or to the destination.
func NewInternalToOCTraceConverter ¶ added in v0.2.7
func NewInternalToOCTraceConverter(tc TraceConsumerOld) TraceConsumer
NewInternalToOCTraceConverter creates new internalToOCTraceConverter that takes TraceConsumer and implements ConsumeTrace interface.
type TraceConsumerBase ¶ added in v0.2.9
type TraceConsumerBase interface{}
TraceConsumerBase defines a common interface for TraceConsumerOld and TraceConsumer.
type TraceConsumerOld ¶ added in v0.2.8
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. |