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
- type ProtocolsArguments
- type RemoteSamplingArguments
Constants ¶
This section is empty.
Variables ¶
View Source
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.
Functions ¶
This section is empty.
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.
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.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.