Back to

package jaegerreceiver

Latest Go to latest
Published: Jun 16, 2020 | License: Apache-2.0 | Module:


func New

func New(
	instanceName string,
	config *Configuration,
	nextConsumer consumer.TraceConsumer,
	params component.ReceiverCreateParams,
) (component.TraceReceiver, error)

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

type Config

type Config struct {
	TypeVal        configmodels.Type         `mapstructure:"-"`
	NameVal        string                    `mapstructure:"-"`
	Protocols      map[string]*SecureSetting `mapstructure:"protocols"`
	RemoteSampling *RemoteSamplingConfig     `mapstructure:"remote_sampling"`

Config defines configuration for Jaeger receiver.

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 configmodels.Type)

SetType sets the receiver type.

func (*Config) Type

func (rs *Config) Type() configmodels.Type

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
	RemoteSamplingClientSettings configgrpc.GRPCClientSettings
	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(
	_ context.Context,
	_ component.ReceiverCreateParams,
	_ configmodels.Receiver,
	_ consumer.MetricsConsumer,
) (component.MetricsReceiver, error)

CreateMetricsReceiver creates a metrics receiver based on provided config.

func (*Factory) CreateTraceReceiver

func (f *Factory) CreateTraceReceiver(
	ctx context.Context,
	params component.ReceiverCreateParams,
	cfg configmodels.Receiver,
	nextConsumer consumer.TraceConsumer,
) (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() configmodels.Type

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

type RemoteSamplingConfig

type RemoteSamplingConfig struct {
	HostEndpoint                  string `mapstructure:"host_endpoint"`
	StrategyFile                  string `mapstructure:"strategy_file"`
	configgrpc.GRPCClientSettings `mapstructure:",squash"`

RemoteSamplingConfig defines config key for remote sampling fetch endpoint

type SecureSetting

type SecureSetting struct {
	configmodels.ReceiverSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct
	// Configures the receiver to use TLS.
	// The default value is nil, which will cause the receiver to not use TLS.
	TLSCredentials *configtls.TLSSetting `mapstructure:"tls_credentials, omitempty"`
Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
f or F : Jump to identifier