Public declaration syntax from forge-go/telemetry/collector.go
Original source SHA-256: e3215141845ecaa04b4859871a4813641016422ec005b36ceb268b38c36503ca
Function bodies and constant values are omitted. This is not the complete implementation.

Source line 12
type CompletedSpan struct

Source line 35
type SpanCollector interface

Source line 53
type NoopCollector struct

Source line 56
func (NoopCollector) RecordSpan(_ CompletedSpan)

Source line 59
func (NoopCollector) Spans() []CompletedSpan

Source line 62
func (NoopCollector) Clear()

Source line 65
func (NoopCollector) Len() int

Source line 68
func (NoopCollector) IsEmpty() bool

Source line 74
type InMemoryCollector struct

Source line 80
func NewInMemoryCollector() *InMemoryCollector

Source line 85
func (c *InMemoryCollector) RecordSpan(span CompletedSpan)

Source line 92
func (c *InMemoryCollector) Spans() []CompletedSpan

Source line 101
func (c *InMemoryCollector) Clear()

Source line 108
func (c *InMemoryCollector) Len() int

Source line 115
func (c *InMemoryCollector) IsEmpty() bool

Source line 134
type InMemoryTelemetry struct

Source line 142
func NewInMemoryTelemetry() *InMemoryTelemetry

Source line 150
func (t *InMemoryTelemetry) StartSpan(name string, agentDID string) SpanID

Source line 165
func (t *InMemoryTelemetry) EndSpan(spanID SpanID) error

Source line 190
func (t *InMemoryTelemetry) EmitEvent(event AuditEvent)

Source line 197
func (t *InMemoryTelemetry) Flush() error

Source line 202
func (t *InMemoryTelemetry) CompletedSpans() []CompletedSpan

Source line 207
func (t *InMemoryTelemetry) Events() []AuditEvent

Source line 216
func (t *InMemoryTelemetry) ActiveSpanCount() int