telemetry

package

Go to main page

Versions in this module

v0

v0.1.3

Oct 9, 2026

v0.1.2

Oct 9, 2026

Changes in this version

type SafeObserver

+ func (o *SafeObserver) Changes() <-chan struct{}

v0.1.1

Oct 9, 2026

Changes in this version

+ const SafeAccountingSchema

+ const SafeDrainLimit

+ const SafeIdentifierLimit

+ const SafeQueueLimit

+ const SafeRecordLimit

+ const SafeSchemaVersion

+ func BindSafeOrigin(ctx context.Context, origin SafeOrigin, category SafeCategory) context.Context

+ func DetachSafeExecution(ctx context.Context, category SafeCategory) context.Context

+ func ReconcileSafe(ctx context.Context, accounting SafeAccounting)

+ func SafeFailureKind(s string) string

+ func WithSafeCategory(ctx context.Context, category SafeCategory) context.Context

+ func WithSafeObserver(ctx context.Context, observer *SafeObserver, execution SafeExecution) (context.Context, error)

+ func WithoutSafeOrigin(ctx context.Context) context.Context

type Context

+ func SafeContext(private Context, ctx context.Context) Context

+ type SafeAccounting struct

+ AttemptCoverage string

+ Complete bool

+ KnownCostUSD *float64

+ PriceState string

+ PricingObserved bool

+ PricingSource string

+ Tokens *SafeTokens

+ UsageObserved bool

+ UsageSource string

+ func NormalizeSafeAccounting(a SafeAccounting) SafeAccounting

+ type SafeAggregate struct

+ Additive bool

+ ReportedCostUSD float64

+ ReportedTokens SafeTokens

+ type SafeAttempt struct

+ func (a *SafeAttempt) Finish(status, failureKind string, accounting SafeAccounting)

+ func (a *SafeAttempt) FinishAdmission(status, failureKind string, accounting SafeAccounting, provider, model string, ...)

+ func (a *SafeAttempt) FinishModel(status, failureKind string, accounting SafeAccounting, provider, model string)

+ type SafeCall struct

+ func NewSafeCall(ctx context.Context) SafeCall

+ func (c SafeCall) StartAttempt(ordinal int, labels SafeLabels) *SafeAttempt

+ type SafeCategory string

+ const CategoryAdvisor

+ const CategoryChild

+ const CategoryCompaction

+ const CategoryMain

+ const CategoryMemory

+ type SafeExecution struct

+ Category SafeCategory

+ ExecutionID string

+ OriginExecutionID string

+ type SafeHealth struct

+ Admitted uint64

+ Capacity int

+ Closed bool

+ ClosedAdmission uint64

+ Complete bool

+ Contended uint64

+ Overflow uint64

+ Oversize uint64

+ Queued int

+ type SafeLabels struct

+ func ApproveModelLabels(provider, model string) (SafeLabels, error)

+ func ApproveToolLabel(tool string) (SafeLabels, error)

+ type SafeObserver struct

+ func NewSafeObserver(options SafeObserverOptions) (*SafeObserver, error)

+ func (o *SafeObserver) Close()

+ func (o *SafeObserver) Drain(limit int) []SafeRecord

+ func (o *SafeObserver) Health() SafeHealth

+ type SafeObserverOptions struct

+ Capacity int

+ RecordBytes int

+ type SafeOrigin struct

+ func CaptureSafeOrigin(ctx context.Context) SafeOrigin

+ func (o SafeOrigin) Merge(other SafeOrigin) SafeOrigin

+ func (o SafeOrigin) SameScope(other SafeOrigin) bool

+ type SafeRecord struct

+ Accounting SafeAccounting

+ AccountingSchema string

+ AttemptID *string

+ AttemptOrdinal int

+ CallID *string

+ Category SafeCategory

+ Duration time.Duration

+ ExecutionID string

+ FailureKind string

+ Kind string

+ LabelsState string

+ ModelID *string

+ OriginExecutionID *string

+ ParentExecutionID *string

+ ParentSpanID *string

+ ProducerAdmitted bool

+ ProducerEventID string

+ ProviderID *string

+ Reconciliation *SafeAggregate

+ SchemaVersion string

+ SettledAt time.Time

+ SpanID *string

+ SpanKind string

+ StartedAt time.Time

+ Status string

+ ToolID *string

+ type SafeTokens struct

+ CacheRead float64

+ CacheWrite float64

+ Input float64

+ Output float64

type Span

+ func (s *Span) SetSafeOutcome(status, failure string)

type SpanOptions

+ SafeLabels SafeLabels

v0.1.0

Oct 8, 2026

Changes in this version

+ const Undefined

+ func StartSpanFrom[T any](c Context, read func() SpanOptions, callback func(*Span) (T, error)) (value T, err error)

+ func StartSpan[T any](c Context, options SpanOptions, callback func(*Span) (T, error)) (value T, err error)

+ func StartTypedSpan[T any](starter SpanStarter, name string, attributes Attributes, ...) (value T, err error)

+ func StringifyValue(value any) ([]byte, error)

+ func WithContext(ctx context.Context, parent Context) context.Context

+ type Array = jsonjs.Array

+ func NewArray(values ...any) *Array

+ type AttributeDefinition struct

+ Cardinality string

+ Description string

+ ElementValues json.RawMessage

+ Examples json.RawMessage

+ Sensitive *bool

+ Type string

+ Values json.RawMessage

+ type Attributes = jsonjs.ObjectValue

+ func NewAttributes(properties ...Property) Attributes

+ type Context struct

+ func FromContext(ctx context.Context) Context

+ func NewContext(start func(SpanOptions, func(*Span) error) error) Context

+ func NewContextWithCallbacks(callbacks ContextCallbacks) Context

+ func (c Context) IsZero() bool

+ func (c Context) StartSpan(options SpanOptions, callback func(*Span) error) (err error)

+ func (c Context) StartSpanFrom(read func() SpanOptions, callback func(*Span) error) error

+ type ContextCallbacks struct

+ StartSpan func(SpanOptions, func(*Span) error) error

+ StartSpanFrom func(func() SpanOptions, func(*Span) error) error

+ type ErrorDetails struct

+ Message string

+ Name string

+ func (e *ErrorDetails) Error() string

+ func (e *ErrorDetails) SetMessageValue(value any)

+ func (e *ErrorDetails) SetNameValue(value any)

+ func (e *ErrorDetails) UnmarshalJSON(data []byte) error

+ func (e ErrorDetails) MarshalJSON() ([]byte, error)

+ func (e ErrorDetails) MessageValue() any

+ func (e ErrorDetails) NameValue() any

+ type EventAttributeDefinition = StartAttributeDefinition

+ type EventDefinition struct

+ Attributes map[string]EventAttributeDefinition

+ Description string

+ type InMemory struct

+ func NewInMemory() *InMemory

+ func (m *InMemory) GetSpanTimings() []SpanTiming

+ func (m *InMemory) GetSpans() []RecordedSpan

+ type JSONMethod = jsonjs.JSONMethod

+ type Object = jsonjs.Object

+ func NewObject(properties ...Property) *Object

+ type ParentDefinition struct

+ Kind string

+ Spans []string

+ func (p ParentDefinition) MarshalJSON() ([]byte, error)

+ type Property = jsonjs.Property

+ type RecordedEvent struct

+ Attributes Attributes

+ Name string

+ func (e *RecordedEvent) UnmarshalJSON(raw []byte) error

+ func (e RecordedEvent) MarshalJSON() ([]byte, error)

+ type RecordedSpan struct

+ Attributes Attributes

+ EndSequence *int

+ Events []RecordedEvent

+ ID int

+ Name string

+ ParentID *int

+ Settled bool

+ Status SpanStatus

+ func (s *RecordedSpan) UnmarshalJSON(raw []byte) error

+ func (s RecordedSpan) MarshalJSON() ([]byte, error)

+ type SchemaDefinition struct

+ Spans map[string]SpanDefinition

+ Version float64

+ func DefineSchema(schema *SchemaDefinition) *SchemaDefinition

+ type Span struct

+ func NewSpan(children Context, callbacks SpanCallbacks) *Span

+ func (s *Span) AddEvent(name string, attributes Attributes)

+ func (s *Span) AddEventFrom(name string, read func() Attributes)

+ func (s *Span) Context() Context

+ func (s *Span) SetAttributes(attributes Attributes)

+ func (s *Span) SetAttributesFrom(read func() Attributes)

+ func (s *Span) SetStatus(status SpanStatus)

+ func (s *Span) SetStatusFrom(read func() SpanStatus)

+ func (s *Span) StartSpan(options SpanOptions, callback func(*Span) error) error

+ func (s *Span) StartSpanFrom(read func() SpanOptions, callback func(*Span) error) error

+ type SpanCallbacks struct

+ AddEvent func(string, Attributes)

+ AddEventFrom func(string, func() Attributes)

+ SetAttributes func(Attributes)

+ SetAttributesFrom func(func() Attributes)

+ SetStatus func(SpanStatus)

+ SetStatusFrom func(func() SpanStatus)

+ type SpanDefinition struct

+ Description string

+ EndAttributes map[string]AttributeDefinition

+ Events map[string]EventDefinition

+ Parents ParentDefinition

+ StartAttributes map[string]StartAttributeDefinition

+ Status StatusDefinition

+ func (s SpanDefinition) MarshalJSON() ([]byte, error)

+ type SpanOptions struct

+ Attributes Attributes

+ Name string

+ func (o *SpanOptions) UnmarshalJSON(raw []byte) error

+ func (o SpanOptions) MarshalJSON() ([]byte, error)

+ type SpanStarter struct

+ func CreateTypedSpanStarter(parent Context, _ ...*SchemaDefinition) SpanStarter

+ func (s SpanStarter) StartSpan(name string, attributes Attributes, callback func(*Span, SpanStarter) error) error

+ type SpanStatus struct

+ Error *ErrorDetails

+ Status string

+ func (s *SpanStatus) UnmarshalJSON(data []byte) error

+ func (s SpanStatus) MarshalJSON() ([]byte, error)

+ type SpanTiming struct

+ Duration time.Duration

+ SpanID int

+ StartedAt time.Time

+ type StartAttributeDefinition struct

+ Required bool

+ type StatusDefinition struct

+ Default string

+ ErrorWhen string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL