receiver

Documentation

Overview

Package recevier implements an OpenTelemetry reciever that connects to Hubble API and can produce trace or logs data.

Index

• func NewFactory() component.ReceiverFactory
• type Config
  • func (cfg *Config) NewOutgoingContext(ctx context.Context) context.Context
  • func (cfg *Config) Validate() error
• type FlowEncodingOptions
• type IncludeFlowTypes

Functions

func NewFactory

func NewFactory() component.ReceiverFactory

Types

type Config

type Config struct {
	config.ReceiverSettings       `mapstructure:",squash"`
	configgrpc.GRPCClientSettings `mapstructure:",squash"`

	BufferSize int `mapstructure:"buffer_size"`

	FlowEncodingOptions FlowEncodingOptions `mapstructure:"flow_encoding_options"`
	IncludeFlowTypes    IncludeFlowTypes    `mapstructure:"include_flow_types"`

	FallbackServiceNamePrefix string        `mapstructure:"fallback_service_name_prefix"`
	TraceCacheWindow          time.Duration `mapstructure:"trace_cache_window"`
	ParseTraceHeaders         bool          `mapstructure:"parse_trace_headers"`
}

func (*Config) NewOutgoingContext

func (cfg *Config) NewOutgoingContext(ctx context.Context) context.Context

func (*Config) Validate

func (cfg *Config) Validate() error

type FlowEncodingOptions

type FlowEncodingOptions struct {
	Traces common.EncodingOptions `mapstructure:"traces"`
	Logs   common.EncodingOptions `mapstructure:"logs"`
}

type IncludeFlowTypes

type IncludeFlowTypes struct {
	Traces common.IncludeFlowTypes `mapstructure:"traces"`
	Logs   common.IncludeFlowTypes `mapstructure:"logs"`
}