jaeger

Documentation

Overview

Package jaeger provides an otelcol.receiver.jaeger component.

Index

• type Arguments
  • func (args Arguments) Convert() (otelcomponent.Config, error)
  • func (args Arguments) DebugMetricsConfig() otelcol.DebugMetricsArguments
  • func (args Arguments) Exporters() map[otelcomponent.DataType]map[otelcomponent.ID]otelcomponent.Component
  • func (args Arguments) Extensions() map[otelcomponent.ID]otelextension.Extension
  • func (args Arguments) NextConsumers() *otelcol.ConsumerArguments
  • func (args *Arguments) Validate() error
• type GRPC
  • func (args *GRPC) Convert() *otelconfiggrpc.GRPCServerSettings
  • func (args *GRPC) SetToDefault()
• type ProtocolUDP
  • func (proto *ProtocolUDP) Convert() *jaegerreceiver.ProtocolUDP
• type ProtocolsArguments
• type ThriftBinary
  • func (args *ThriftBinary) Convert() *jaegerreceiver.ProtocolUDP
  • func (args *ThriftBinary) SetToDefault()
• type ThriftCompact
  • func (args *ThriftCompact) Convert() *jaegerreceiver.ProtocolUDP
  • func (args *ThriftCompact) SetToDefault()
• type ThriftHTTP
  • func (args *ThriftHTTP) Convert() *otelconfighttp.HTTPServerSettings
  • func (args *ThriftHTTP) SetToDefault()

Types

type Arguments

type Arguments struct {
	Protocols ProtocolsArguments `river:"protocols,block"`

	// DebugMetrics configures component internal metrics. Optional.
	DebugMetrics otelcol.DebugMetricsArguments `river:"debug_metrics,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() (otelcomponent.Config, error)

Convert implements receiver.Arguments.

func (Arguments) DebugMetricsConfig

func (args Arguments) DebugMetricsConfig() otelcol.DebugMetricsArguments

DebugMetricsConfig implements receiver.Arguments.

func (Arguments) Exporters

func (args Arguments) Exporters() map[otelcomponent.DataType]map[otelcomponent.ID]otelcomponent.Component

Exporters implements receiver.Arguments.

func (Arguments) Extensions

func (args Arguments) Extensions() map[otelcomponent.ID]otelextension.Extension

Extensions implements receiver.Arguments.

func (Arguments) NextConsumers

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

NextConsumers implements receiver.Arguments.

func (*Arguments) Validate

func (args *Arguments) Validate() error

Validate implements river.Validator.

type GRPC

type GRPC struct {
	GRPCServerArguments *otelcol.GRPCServerArguments `river:",squash"`
}

func (*GRPC) Convert

func (args *GRPC) Convert() *otelconfiggrpc.GRPCServerSettings

Convert converts proto into the upstream type.

func (*GRPC) SetToDefault

func (args *GRPC) SetToDefault()

SetToDefault implements river.Defaulter.

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          *GRPC          `river:"grpc,block,optional"`
	ThriftHTTP    *ThriftHTTP    `river:"thrift_http,block,optional"`
	ThriftBinary  *ThriftBinary  `river:"thrift_binary,block,optional"`
	ThriftCompact *ThriftCompact `river:"thrift_compact,block,optional"`
}

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

type ThriftBinary

type ThriftBinary struct {
	ProtocolUDP *ProtocolUDP `river:",squash"`
}

ThriftCompact wraps ProtocolUDP and provides additional behavior.

func (*ThriftBinary) Convert

func (args *ThriftBinary) Convert() *jaegerreceiver.ProtocolUDP

Convert converts proto into the upstream type.

func (*ThriftBinary) SetToDefault

func (args *ThriftBinary) SetToDefault()

SetToDefault implements river.Defaulter.

type ThriftCompact

type ThriftCompact struct {
	ProtocolUDP *ProtocolUDP `river:",squash"`
}

ThriftCompact wraps ProtocolUDP and provides additional behavior.

func (*ThriftCompact) Convert

func (args *ThriftCompact) Convert() *jaegerreceiver.ProtocolUDP

Convert converts proto into the upstream type.

func (*ThriftCompact) SetToDefault

func (args *ThriftCompact) SetToDefault()

SetToDefault implements river.Defaulter.

type ThriftHTTP

type ThriftHTTP struct {
	HTTPServerArguments *otelcol.HTTPServerArguments `river:",squash"`
}

func (*ThriftHTTP) Convert

func (args *ThriftHTTP) Convert() *otelconfighttp.HTTPServerSettings

Convert converts proto into the upstream type.

func (*ThriftHTTP) SetToDefault

func (args *ThriftHTTP) SetToDefault()

SetToDefault implements river.Defaulter.