otelreceiver

Documentation

Overview

Package otelreceiver provides simple wrapper to setup trace receiver.

Index

• type Consumers
• type LogsConsumer
• type MetricsConsumer
• type Receiver
  • func NewReceiver(consumers Consumers, cfg ReceiverConfig) (*Receiver, error)
  • func (r *Receiver) GetExporters() map[component.DataType]map[component.ID]component.Component
  • func (r *Receiver) GetExtensions() map[component.ID]extension.Extension
  • func (r *Receiver) GetFactory(component.Kind, component.Type) component.Factory
  • func (r *Receiver) ReportFatalError(err error)
  • func (r *Receiver) Run(ctx context.Context) (rerr error)
• type ReceiverConfig
• type TracesConsumer

Types

type Consumers

type Consumers struct {
	Traces  TracesConsumer
	Metrics MetricsConsumer
	Logs    LogsConsumer
}

Consumers is a set of telemetry consumers.

type LogsConsumer

type LogsConsumer interface {
	ConsumeLogs(ctx context.Context, ld plog.Logs) error
}

LogsConsumer is logs consumer.

type MetricsConsumer

type MetricsConsumer interface {
	ConsumeMetrics(ctx context.Context, ld pmetric.Metrics) error
}

MetricsConsumer is metrics consumer.

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

Receiver is a OpenTelemetry-compatible trace receiver.

func NewReceiver

func NewReceiver(consumers Consumers, cfg ReceiverConfig) (*Receiver, error)

NewReceiver setups trace receiver.

func (*Receiver) GetExporters

func (r *Receiver) GetExporters() map[component.DataType]map[component.ID]component.Component

GetExporters implements component.Host

func (*Receiver) GetExtensions

func (r *Receiver) GetExtensions() map[component.ID]extension.Extension

GetExtensions implements component.Host

func (*Receiver) GetFactory

func (r *Receiver) GetFactory(component.Kind, component.Type) component.Factory

GetFactory implements component.Host

func (*Receiver) ReportFatalError

func (r *Receiver) ReportFatalError(err error)

ReportFatalError implements component.Host

func (*Receiver) Run

func (r *Receiver) Run(ctx context.Context) (rerr error)

Run setups corresponding listeners.

type ReceiverConfig

type ReceiverConfig struct {
	OTELConfig     map[string]any
	TracerProvider trace.TracerProvider
	MeterProvider  metric.MeterProvider
	Logger         *zap.Logger
}

ReceiverConfig is a config struct for Receiver.

type TracesConsumer

type TracesConsumer interface {
	ConsumeTraces(ctx context.Context, td ptrace.Traces) error
}

TracesConsumer is traces consumer.