collector

Documentation

Index

• func Start(ctx context.Context, config Config, tracer trace.Tracer, ...) (stoppable, error)
• type CollectorOption
  • func WithStartRemoteServer(startRemoteServer bool) CollectorOption
  • func WithTraceCache(traceCache TraceCache) CollectorOption
• type Config
• type TraceCache
  • func NewTraceCache() TraceCache

Functions

func Start

func Start(ctx context.Context, config Config, tracer trace.Tracer, opts ...CollectorOption) (stoppable, error)

Types

type CollectorOption

type CollectorOption func(*remoteIngesterConfig)

func WithStartRemoteServer

func WithStartRemoteServer(startRemoteServer bool) CollectorOption

func WithTraceCache

func WithTraceCache(traceCache TraceCache) CollectorOption

type Config

type Config struct {
	HTTPPort          int
	GRPCPort          int
	BatchTimeout      time.Duration
	RemoteServerURL   string
	RemoteServerToken string
}

type TraceCache

type TraceCache interface {
	Get(string) ([]*v1.Span, bool)
	Set(string, []*v1.Span)
}

func NewTraceCache

func NewTraceCache() TraceCache