otlpgrpc

Documentation

Index

• type Config
  • func (cfg *Config) Validate() error
• type Forwarder
  • func NewForwarder(cfg Config, logger log.Logger) (*Forwarder, error)
  • func (f *Forwarder) Dial(ctx context.Context, opts ...grpc.DialOption) error
  • func (f *Forwarder) ForwardTraces(ctx context.Context, traces ptrace.Traces) error
  • func (f *Forwarder) Shutdown(_ context.Context) error
• type TLSConfig
  • func (cfg *TLSConfig) Validate() error

Types

type Config

type Config struct {
	Endpoints flagext.StringSlice `yaml:"endpoints"`
	TLS       TLSConfig           `yaml:"tls"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

type Forwarder

type Forwarder struct {
	// contains filtered or unexported fields
}

func NewForwarder

func NewForwarder(cfg Config, logger log.Logger) (*Forwarder, error)

func (*Forwarder) Dial

func (f *Forwarder) Dial(ctx context.Context, opts ...grpc.DialOption) error

Dial creates client connections and clients based on config. Dial is expected to be called only once.

func (*Forwarder) ForwardTraces

func (f *Forwarder) ForwardTraces(ctx context.Context, traces ptrace.Traces) error

func (*Forwarder) Shutdown

func (f *Forwarder) Shutdown(_ context.Context) error

type TLSConfig

type TLSConfig struct {
	Insecure bool   `yaml:"insecure"`
	CertFile string `yaml:"cert_file"`
}

func (*TLSConfig) Validate

func (cfg *TLSConfig) Validate() error