server

Documentation

Index

• Variables
• func GetMetrics() []string
• func Reset()
• func Start(ctx context.Context, cancel context.CancelFunc)
• type ConsumeEvent
• type Datapoints
  • func GetDatapoints(name string) *Datapoints
• type Log
  • func GetLogs() []*Log
• type Payload
  • func GetPayloads() []*Payload
• type Span
• type Trace
  • func GetTraces() []*Trace

Variables

var Send func(msg any)

var Storage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Functions

func GetMetrics

func GetMetrics() []string

func Reset

func Reset()

func Start

func Start(ctx context.Context, cancel context.CancelFunc)

NewReceiver creates a new OTLP receiver

Types

type ConsumeEvent

type ConsumeEvent struct {
	Payloads int
	Logs     int
	Spans    int
	Metrics  int
}

type Datapoints

type Datapoints struct {
	Times  []uint64
	Values []float64
}

func GetDatapoints

func GetDatapoints(name string) *Datapoints

type Log

type Log struct {
	Received     time.Time
	Log          *logs.LogRecord
	ResourceLogs *logs.ResourceLogs
	ScopeLogs    *logs.ScopeLogs
}

func GetLogs

func GetLogs() []*Log

type Payload

type Payload struct {
	Received time.Time
	Num      int
	Payload  any
}

func GetPayloads

func GetPayloads() []*Payload

type Span

type Span struct {
	Span     *traces.Span
	Resource *resource.Resource
	Scope    *v1.InstrumentationScope
}

type Trace

type Trace struct {
	TraceID string
	Spans   []*Span
}

func GetTraces

func GetTraces() []*Trace