zipkinreceiver

Documentation

Index

• 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
• type ZipkinReceiver
  • func New(address string, nextConsumer consumer.TraceConsumer) (*ZipkinReceiver, error)
  • func (zr *ZipkinReceiver) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (zr *ZipkinReceiver) StartTraceReception(host receiver.Host) error
  • func (zr *ZipkinReceiver) StopTraceReception() error
  • func (zr *ZipkinReceiver) TraceSource() string

Types

type Config

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

Config defines configuration for Zipkin receiver.

type Factory

type Factory struct {
}

Factory is the factory for Zipkin 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.

type ZipkinReceiver

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

ZipkinReceiver type is used to handle spans received in the Zipkin format.

func New

func New(address string, nextConsumer consumer.TraceConsumer) (*ZipkinReceiver, error)

New creates a new zipkinreceiver.ZipkinReceiver reference.

func (*ZipkinReceiver) ServeHTTP

func (zr *ZipkinReceiver) ServeHTTP(w http.ResponseWriter, r *http.Request)

The ZipkinReceiver receives spans from endpoint /api/v2 as JSON, unmarshals them and sends them along to the nextConsumer.

func (*ZipkinReceiver) StartTraceReception

func (zr *ZipkinReceiver) StartTraceReception(host receiver.Host) error

StartTraceReception spins up the receiver's HTTP server and makes the receiver start its processing.

func (*ZipkinReceiver) StopTraceReception

func (zr *ZipkinReceiver) StopTraceReception() error

StopTraceReception tells the receiver that should stop reception, giving it a chance to perform any necessary clean-up and shutting down its HTTP server.

func (*ZipkinReceiver) TraceSource

func (zr *ZipkinReceiver) TraceSource() string

TraceSource returns the name of the trace data source.