zipkinscribereceiver

Documentation

Overview

Package zipkinscribereceiver implements a receiver that can be used by the OpenTelemetry service to receive traces in the Zipkin-Scribe format.

Index

• func New(addr string, category string, nextConsumer consumer.TraceConsumer) (receiver.TraceReceiver, error)
• type Config
• type Factory
  • func (f *Factory) CreateDefaultConfig() configmodels.Receiver
  • func (f *Factory) CreateMetricsReceiver(logger *zap.Logger, cfg configmodels.Receiver, ...) (receiver.MetricsReceiver, error)
  • func (f *Factory) CreateTraceReceiver(ctx context.Context, logger *zap.Logger, cfg configmodels.Receiver, ...) (receiver.TraceReceiver, error)
  • func (f *Factory) CustomUnmarshaler() receiver.CustomUnmarshaler
  • func (f *Factory) Type() string

Functions

func New

func New(
	addr string,
	category string,
	nextConsumer consumer.TraceConsumer) (receiver.TraceReceiver, error)

New creates the Zipkin Scribe receiver with the given parameters.

Types

type Config

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

	// Category is the string that will be used to identify the scribe log
	// messages that contain Zipkin spans.
	Category string `mapstructure:"category"`
}

Config defines configuration for Zipkin-Scribe receiver.

type Factory

type Factory struct {
}

Factory is the factory for Zipkin-Scribe receiver.

func (*Factory) CreateDefaultConfig

func (f *Factory) CreateDefaultConfig() configmodels.Receiver

CreateDefaultConfig creates the default configuration for Jaeger receiver.

func (*Factory) CreateMetricsReceiver

func (f *Factory) CreateMetricsReceiver(
	logger *zap.Logger,
	cfg configmodels.Receiver,
	consumer consumer.MetricsConsumer,
) (receiver.MetricsReceiver, error)

CreateMetricsReceiver creates a metrics receiver based on provided config.

func (*Factory) CreateTraceReceiver

func (f *Factory) CreateTraceReceiver(
	ctx context.Context,
	logger *zap.Logger,
	cfg configmodels.Receiver,
	nextConsumer consumer.TraceConsumer,
) (receiver.TraceReceiver, error)

CreateTraceReceiver creates a trace receiver based on provided config.

func (*Factory) CustomUnmarshaler

func (f *Factory) CustomUnmarshaler() receiver.CustomUnmarshaler

CustomUnmarshaler returns nil because we don't need custom unmarshaling for this config.

func (*Factory) Type

func (f *Factory) Type() string

Type gets the type of the Receiver config created by this factory.