consumer

package
v0.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

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 BaseTraceConsumer added in v0.2.7

type BaseTraceConsumer interface{}

BaseTraceConsumer defines a common interface for TraceConsumer and TraceConsumerV2.

type MetricsConsumer

type MetricsConsumer interface {
	ConsumeMetricsData(ctx context.Context, md consumerdata.MetricsData) error
}

MetricsConsumer 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 MetricsConsumerV2 added in v0.2.7

type MetricsConsumerV2 interface {
	ConsumeMetricsV2(ctx context.Context, md data.MetricData) error
}

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

type TraceConsumer

type TraceConsumer interface {
	BaseTraceConsumer
	ConsumeTraceData(ctx context.Context, td consumerdata.TraceData) error
}

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

type TraceConsumerV2 added in v0.2.7

type TraceConsumerV2 interface {
	BaseTraceConsumer
	// ConsumeTraceV2 receives data.TraceData for processing.
	ConsumeTraceV2(ctx context.Context, td data.TraceData) error
}

TraceConsumerV2 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 TraceConsumer) TraceConsumerV2

NewInternalToOCTraceConverter creates new internalToOCTraceConverter that takes TraceConsumer and implements ConsumeTraceV2 interface.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL