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.
Variables ¶
This section is empty.
Functions ¶
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.
type OptionsFactory ¶
type OptionsFactory func() *ingesterApp.Options
OptionsFactory returns initialized ingester app.Options structure.