jaeger

Documentation

Overview

Package jaeger provides an otelcol.receiver.jaeger component.

Index

• type Arguments
  • func (args Arguments) Convert() (otelcomponent.Config, error)
  • 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"`

	// 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) 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.