tracer

Documentation

Index

• func InitOpenTelemetry(exporter sdktrace.SpanExporter) trace.Tracer
• type SpanCollector
  • func NewSpanCollector(ctx context.Context) *SpanCollector
  • func (c *SpanCollector) Close() error
  • func (c *SpanCollector) ExportSpans(ctx context.Context, spans []*trace.SpanSnapshot) error
  • func (c *SpanCollector) GetOutgoingSpans() (io.Reader, func(), error)
  • func (c *SpanCollector) Shutdown(ctx context.Context) error
• type SpanSource

Functions

func InitOpenTelemetry

func InitOpenTelemetry(exporter sdktrace.SpanExporter) trace.Tracer

Types

type SpanCollector

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

SpanCollector does 3 things: 1) Accepts spans from OpenTelemetry. 2) Stores spans (for now, in memory) 3) Allows consumers to read spans they might want to send elsewhere Numbers 2 and 3 access the same data, and so it's a concurrency issue.

func NewSpanCollector

func NewSpanCollector(ctx context.Context) *SpanCollector

func (*SpanCollector) Close

func (c *SpanCollector) Close() error

func (*SpanCollector) ExportSpans

func (c *SpanCollector) ExportSpans(ctx context.Context, spans []*trace.SpanSnapshot) error

func (*SpanCollector) GetOutgoingSpans

func (c *SpanCollector) GetOutgoingSpans() (io.Reader, func(), error)

SpanSource

func (*SpanCollector) Shutdown

func (c *SpanCollector) Shutdown(ctx context.Context) error

type SpanSource

type SpanSource interface {
	// GetOutgoingSpans gives a consumer access to spans they should send
	// If there are no outgoing spans, err will be io.EOF
	// rejectFn allows client to reject spans, so they can be requeued
	// rejectFn must be called, if at all, before the next call to GetOutgoingSpans
	GetOutgoingSpans() (data io.Reader, rejectFn func(), err error)

	// Close closes the SpanSource; the client may not interact with this SpanSource after calling Close
	Close() error
}

SpanSource is the interface for consumers (generally telemetry.Controller)