flags

Documentation

Index

• Constants
• func AddFlags(flagSet *flag.FlagSet)
• type CollectorOptions
  • func (cOpts *CollectorOptions) InitFromViper(v *viper.Viper, _ *zap.Logger) (*CollectorOptions, error)

Constants

const (

	// DefaultNumWorkers is the default number of workers consuming from the processor queue
	DefaultNumWorkers = 50
	// DefaultQueueSize is the size of the processor's queue
	DefaultQueueSize = 2000
	// DefaultGRPCMaxReceiveMessageLength is the default max receivable message size for the gRPC Collector
	DefaultGRPCMaxReceiveMessageLength = 4 * 1024 * 1024
)

Functions

func AddFlags

func AddFlags(flagSet *flag.FlagSet)

AddFlags adds flags for CollectorOptions

Types

type CollectorOptions

type CollectorOptions struct {
	// DynQueueSizeMemory determines how much memory to use for the queue
	DynQueueSizeMemory uint
	// QueueSize is the size of collector's queue
	QueueSize uint
	// NumWorkers is the number of internal workers in a collector
	NumWorkers int
	// HTTP section defines options for HTTP server
	HTTP confighttp.ServerConfig
	// GRPC section defines options for gRPC server
	GRPC configgrpc.ServerConfig
	// OTLP section defines options for servers accepting OpenTelemetry OTLP format
	OTLP struct {
		Enabled bool
		GRPC    configgrpc.ServerConfig
		HTTP    confighttp.ServerConfig
	}
	// Zipkin section defines options for Zipkin HTTP server
	Zipkin struct {
		confighttp.ServerConfig
		KeepAlive bool
	}
	// CollectorTags is the string representing collector tags to append to each and every span
	CollectorTags map[string]string
	// SpanSizeMetricsEnabled determines whether to enable metrics based on processed span size
	SpanSizeMetricsEnabled bool

	Tenancy tenancy.Options
}

CollectorOptions holds configuration for collector

func (*CollectorOptions) InitFromViper

func (cOpts *CollectorOptions) InitFromViper(v *viper.Viper, _ *zap.Logger) (*CollectorOptions, error)

InitFromViper initializes CollectorOptions with properties from viper