jaegerreceiver

Documentation

Index

• func New(instanceName string, config *Configuration, ...) (component.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, ...) (component.MetricsReceiver, error)
  • func (f *Factory) CreateTraceReceiver(ctx context.Context, logger *zap.Logger, cfg configmodels.Receiver, ...) (component.TraceReceiver, error)
  • func (f *Factory) CustomUnmarshaler() component.CustomUnmarshaler
  • func (f *Factory) Type() string
• type RemoteSamplingConfig

Functions

func New

func New(
	instanceName string,
	config *Configuration,
	nextConsumer consumer.TraceConsumerOld,
	logger *zap.Logger,
) (component.TraceReceiver, error)

New creates a TraceReceiver that receives traffic as a Jaeger collector, and also as a Jaeger agent.

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
	RemoteSamplingStrategyFile 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.MetricsConsumerOld,
) (component.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.TraceConsumerOld,
) (component.TraceReceiver, error)

CreateTraceReceiver creates a trace receiver based on provided config.

func (*Factory) CustomUnmarshaler

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

CustomUnmarshaler is used to add defaults for named but empty protocols

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 {
	HostEndpoint  string `mapstructure:"host_endpoint"`
	FetchEndpoint string `mapstructure:"fetch_endpoint"`
	StrategyFile  string `mapstructure:"strategy_file"`
}

RemoteSamplingConfig defines config key for remote sampling fetch endpoint