jaegerreceiver

Documentation

Index

• func New(ctx context.Context, config *Configuration, ...) (receiver.TraceReceiver, error)
• type Config
  • func (rs *Config) IsEnabled() bool
  • func (rs *Config) Name() string
  • func (rs *Config) SetName(name string)
  • func (rs *Config) SetType(typeStr string)
  • func (rs *Config) Type() string
• type Configuration
• 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 RemoteSamplingConfig

Functions

func New

func New(ctx context.Context, config *Configuration, nextConsumer consumer.TraceConsumer, logger *zap.Logger) (receiver.TraceReceiver, error)

New creates a TraceReceiver that receives traffic as a collector with both Thrift and HTTP transports.

Types

type Config

type Config struct {
	TypeVal        string                                      `mapstructure:"-"`
	NameVal        string                                      `mapstructure:"-"`
	Protocols      map[string]*receiver.SecureReceiverSettings `mapstructure:"protocols"`
	RemoteSampling *RemoteSamplingConfig                       `mapstructure:"remote_sampling"`
}

Config defines configuration for Jaeger receiver.

func (*Config) IsEnabled

func (rs *Config) IsEnabled() bool

IsEnabled returns true if the entity is enabled.

func (*Config) Name

func (rs *Config) Name() string

Name gets the receiver name.

func (*Config) SetName

func (rs *Config) SetName(name string)

SetName sets the receiver name.

func (*Config) SetType

func (rs *Config) SetType(typeStr string)

SetType sets the receiver type.

func (*Config) Type

func (rs *Config) Type() string

Type sets the receiver type.

type Configuration

type Configuration struct {
	CollectorThriftPort  int
	CollectorHTTPPort    int
	CollectorGRPCPort    int
	CollectorGRPCOptions []grpc.ServerOption

	AgentCompactThriftPort int
	AgentBinaryThriftPort  int
	AgentHTTPPort          int
	RemoteSamplingEndpoint string
}

Configuration defines the behavior and the ports that the Jaeger receiver will use.

type Factory

type Factory struct {
}

Factory is the factory for Jaeger 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 RemoteSamplingConfig

type RemoteSamplingConfig struct {
	FetchEndpoint string `mapstructure:"fetch_endpoint"`
}

RemoteSamplingConfig defines config key for remote sampling fetch endpoint