forwarder

Documentation

Index

• Constants
• type Config
  • func (cfg *Config) Validate() error
• type ConfigList
  • func (cfgs ConfigList) Validate() error
• type Forwarder
  • func New(cfg Config, logger log.Logger) (Forwarder, error)
• type List
  • func (l List) ForwardSnapshot(ctx context.Context, snapshot *tp.Snapshot) error
  • func (l List) ForwardTraces(ctx context.Context, traces ptrace.Traces) error
• type Manager
  • func NewManager(cfgs ConfigList, logger log.Logger, overrides Overrides) (*Manager, error)
  • func (m *Manager) ForTenant(tenantID string) List
• type Overrides

Constants

const (
	OTLPGRPCBackend = "otlpgrpc"
)

Types

type Config

type Config struct {
	Name     string          `yaml:"name"`
	Backend  string          `yaml:"backend"`
	OTLPGRPC otlpgrpc.Config `yaml:"otlpgrpc"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

type ConfigList

type ConfigList []Config

func (ConfigList) Validate

func (cfgs ConfigList) Validate() error

type Forwarder

type Forwarder interface {
	ForwardTraces(ctx context.Context, traces ptrace.Traces) error
	Shutdown(ctx context.Context) error
}

func New

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

type List

type List []Forwarder

func (List) ForwardSnapshot

func (l List) ForwardSnapshot(ctx context.Context, snapshot *tp.Snapshot) error

func (List) ForwardTraces

func (l List) ForwardTraces(ctx context.Context, traces ptrace.Traces) error

type Manager

type Manager struct {
	services.Service
	// contains filtered or unexported fields
}

func NewManager

func NewManager(cfgs ConfigList, logger log.Logger, overrides Overrides) (*Manager, error)

func (*Manager) ForTenant

func (m *Manager) ForTenant(tenantID string) List

type Overrides

type Overrides interface {
	TenantIDs() []string
	Forwarders(tenantID string) []string
}