kafkareceiver

Documentation

Overview

Package kafkareceiver implements Jaeger Kafka consumer as OpenTelemetry receiver.

Index

• Constants
• func AddFlags(flags *flag.FlagSet)
• func DefaultOptions() *ingesterApp.Options
• type Config
• type Factory
  • func (f Factory) CreateDefaultConfig() configmodels.Receiver
  • func (f Factory) CreateMetricsReceiver(_ context.Context, _ component.ReceiverCreateParams, _ configmodels.Receiver, ...) (component.MetricsReceiver, error)
  • func (f Factory) CreateTraceReceiver(_ context.Context, params component.ReceiverCreateParams, ...) (component.TraceReceiver, error)
  • func (f Factory) CustomUnmarshaler() component.CustomUnmarshaler
  • func (f Factory) Type() configmodels.Type
• type OptionsFactory

Constants

const TypeStr = "jaeger_kafka"

TypeStr defines exporter type.

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

AddFlags adds Ingester flags.

func DefaultOptions

func DefaultOptions() *ingesterApp.Options

DefaultOptions creates Kafka options supported by this receiver.

Types

type Config

type Config struct {
	configmodels.ReceiverSettings `mapstructure:",squash"`
	ingesterApp.Options           `mapstructure:",squash"`
}

Config hold configuration for Jaeger kafka receiver/ingester.

type Factory

type Factory struct {
	OptionsFactory OptionsFactory
}

Factory is used to build the receiver.

func (Factory) CreateDefaultConfig

func (f Factory) CreateDefaultConfig() configmodels.Receiver

CreateDefaultConfig creates default config. This function implements OTEL component.ReceiverFactoryBase interface.

func (Factory) CreateMetricsReceiver

func (f Factory) CreateMetricsReceiver(
	_ context.Context,
	_ component.ReceiverCreateParams,
	_ configmodels.Receiver,
	_ consumer.MetricsConsumer,
) (component.MetricsReceiver, error)

CreateMetricsReceiver returns metrics receiver. This function implements OTEL component.ReceiverFactory.

func (Factory) CreateTraceReceiver

func (f Factory) CreateTraceReceiver(
	_ context.Context,
	params component.ReceiverCreateParams,
	cfg configmodels.Receiver,
	nextConsumer consumer.TraceConsumer,
) (component.TraceReceiver, error)

CreateTraceReceiver returns Kafka receiver. This function implements OTEL component.ReceiverFactory.

func (Factory) CustomUnmarshaler

func (f Factory) CustomUnmarshaler() component.CustomUnmarshaler

CustomUnmarshaler returns custom marshaller. This function implements OTEL component.ReceiverFactoryBase interface.

func (Factory) Type

func (f Factory) Type() configmodels.Type

Type returns the receiver type.

type OptionsFactory

type OptionsFactory func() *ingesterApp.Options

OptionsFactory returns initialized ingester app.Options structure.