collector

Documentation

Index

• type Collector
  • func GetActiveCollector() Collector
  • func Start(ctx context.Context, config Config, tracer trace.Tracer, ...) (Collector, error)
• type CollectorOption
  • func WithLogger(logger *zap.Logger) CollectorOption
  • func WithObserver(observer event.Observer) CollectorOption
  • func WithSensor(sensor sensors.Sensor) CollectorOption
  • func WithStartRemoteServer(startRemoteServer bool) CollectorOption
  • func WithTraceCache(traceCache TraceCache) CollectorOption
• type Config
• type Statistics
• type TraceCache
  • func NewTraceCache() TraceCache

Types

type Collector

type Collector interface {
	Statistics() Statistics
	ResetStatistics()

	SetSensor(sensors.Sensor)
	// contains filtered or unexported methods
}

func GetActiveCollector

func GetActiveCollector() Collector

func Start

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

type CollectorOption

type CollectorOption func(*remoteIngesterConfig)

func WithLogger

func WithLogger(logger *zap.Logger) CollectorOption

func WithObserver

func WithObserver(observer event.Observer) CollectorOption

func WithSensor

func WithSensor(sensor sensors.Sensor) CollectorOption

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 Statistics

type Statistics struct {
	SpanCount         int64
	LastSpanTimestamp time.Time
}

type TraceCache

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

func NewTraceCache

func NewTraceCache() TraceCache