jaeger

Documentation

Overview

Package jaeger provides an otelcol.receiver.jaeger component.

Index

• Variables
• type Arguments
  • func (args Arguments) Convert() otelconfig.Receiver
  • func (args Arguments) Exporters() map[otelconfig.DataType]map[otelconfig.ComponentID]otelcomponent.Exporter
  • func (args Arguments) Extensions() map[otelconfig.ComponentID]otelcomponent.Extension
  • func (args Arguments) NextConsumers() *otelcol.ConsumerArguments
  • func (args *Arguments) UnmarshalRiver(f func(interface{}) error) error
  • func (args *Arguments) Validate() error
• type ProtocolUDP
  • func (proto *ProtocolUDP) Convert() *jaegerreceiver.ProtocolUDP
• type ProtocolsArguments
• type RemoteSamplingArguments
  • func (args *RemoteSamplingArguments) Convert() *jaegerreceiver.RemoteSamplingConfig

Variables

var DefaultArguments = Arguments{
	Protocols: ProtocolsArguments{
		GRPC: &otelcol.GRPCServerArguments{
			Endpoint:  "0.0.0.0:14250",
			Transport: "tcp",
		},
		ThriftHTTP: &otelcol.HTTPServerArguments{
			Endpoint: "0.0.0.0:14268",
		},
		ThriftBinary: &ProtocolUDP{
			Endpoint:      "0.0.0.0:6832",
			QueueSize:     1_000,
			MaxPacketSize: 65 * units.KiB,
			Workers:       10,
		},
		ThriftCompact: &ProtocolUDP{
			Endpoint:      "0.0.0.0:6831",
			QueueSize:     1_000,
			MaxPacketSize: 65 * units.KiB,
			Workers:       10,
		},
	},
}

DefaultArguments provides default settings for Arguments. All protocols are configured with defaults and then set to nil in UnmarshalRiver if they were not defined in the source config.

Types

type Arguments

type Arguments struct {
	Protocols      ProtocolsArguments       `river:"protocols,block"`
	RemoteSampling *RemoteSamplingArguments `river:"remote_sampling,block,optional"`

	// Output configures where to send received data. Required.
	Output *otelcol.ConsumerArguments `river:"output,block"`
}

Arguments configures the otelcol.receiver.jaeger component.

func (Arguments) Convert

func (args Arguments) Convert() otelconfig.Receiver

Convert implements receiver.Arguments.

func (Arguments) Exporters

func (args Arguments) Exporters() map[otelconfig.DataType]map[otelconfig.ComponentID]otelcomponent.Exporter

Exporters implements receiver.Arguments.

func (Arguments) Extensions

func (args Arguments) Extensions() map[otelconfig.ComponentID]otelcomponent.Extension

Extensions implements receiver.Arguments.

func (Arguments) NextConsumers

func (args Arguments) NextConsumers() *otelcol.ConsumerArguments

NextConsumers implements receiver.Arguments.

func (*Arguments) UnmarshalRiver

func (args *Arguments) UnmarshalRiver(f func(interface{}) error) error

UnmarshalRiver implements river.Unmarshaler.

func (*Arguments) Validate

func (args *Arguments) Validate() error

Validate returns an error if args is invalid.

type ProtocolUDP

type ProtocolUDP struct {
	Endpoint         string           `river:"endpoint,attr,optional"`
	QueueSize        int              `river:"queue_size,attr,optional"`
	MaxPacketSize    units.Base2Bytes `river:"max_packet_size,attr,optional"`
	Workers          int              `river:"workers,attr,optional"`
	SocketBufferSize units.Base2Bytes `river:"socket_buffer_size,attr,optional"`
}

ProtocolUDP configures a UDP server.

func (*ProtocolUDP) Convert

func (proto *ProtocolUDP) Convert() *jaegerreceiver.ProtocolUDP

Convert converts proto into the upstream type.

type ProtocolsArguments

type ProtocolsArguments struct {
	GRPC          *otelcol.GRPCServerArguments `river:"grpc,block,optional"`
	ThriftHTTP    *otelcol.HTTPServerArguments `river:"thrift_http,block,optional"`
	ThriftBinary  *ProtocolUDP                 `river:"thrift_binary,block,optional"`
	ThriftCompact *ProtocolUDP                 `river:"thrift_compact,block,optional"`
}

ProtocolsArguments configures protocols for otelcol.receiver.jaeger to listen on.

type RemoteSamplingArguments

type RemoteSamplingArguments struct {
	HostEndpoint               string                      `river:"host_endpoint,attr"`
	StrategyFile               string                      `river:"strategy_file,attr"`
	StrategyFileReloadInterval time.Duration               `river:"strategy_file_reload_interval,attr"`
	Client                     otelcol.GRPCClientArguments `river:"client,block"`
}

RemoteSamplingArguments configures remote sampling settings.

func (*RemoteSamplingArguments) Convert

func (args *RemoteSamplingArguments) Convert() *jaegerreceiver.RemoteSamplingConfig

Convert converts args into the upstream type.