consumer

package
v0.25.0 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2021 License: Apache-2.0 Imports: 2 Imported by: 601

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

Jump to

Keyboard shortcuts

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