oltgo

package module

Go to main page

Versions in this module

v1

v1.1.0

Aug 4, 2026

Changes in this version

+ func IsFailureSeverity(s Severity) bool

type Agent

+ func NewAgentWithOptions(service Service, env Environment, schemaVersion string, ...) *Agent

+ func (a *Agent) Stats() ShippingStats

type Environment

+ const Staging

type EventBuilder

+ func (eb *EventBuilder) Fail() *EventBuilder

+ func (eb *EventBuilder) Succeed() *EventBuilder

+ type Options struct

+ BufferSize int

+ OnError func(LogSchema, error)

type Shipping

+ func (s *Shipping) Stats() ShippingStats

+ type ShippingStats struct

+ Dropped int64

+ Failed int64

+ QueueCapacity int

+ QueueDepth int

+ Shipped int64

v1.0.0

Aug 3, 2026

v0

v0.0.2

Jun 3, 2026

Changes in this version

+ func ActiveEventFromContext(ctx context.Context) string

+ func WithActiveEvent(ctx context.Context, eventID string) context.Context

type Event

+ Events []*Event

type EventBuilder

+ func StartEvent(ctx context.Context, name string, eventType EventType, severity Severity) (context.Context, *EventBuilder)

v0.0.1

Jun 1, 2026

Changes in this version

+ func WithCollection(ctx context.Context, c *Collection) context.Context

+ type Actor struct

+ ID string

+ IP string

+ Type string

+ type Agent struct

+ Env Environment

+ SchemaVersion string

+ Service Service

+ Shipping *Shipping

+ func NewAgent(service Service, env Environment, schemaVersion string, ...) *Agent

+ func (a *Agent) Close()

+ func (a *Agent) NewCollection(tracingID string) *Collection

+ type Collection struct

+ func FromContext(ctx context.Context) *Collection

+ func NewCollection(agent *Agent, tracingID string) *Collection

+ func (c *Collection) AddEvent(event Event)

+ func (c *Collection) Commit()

+ func (c *Collection) SetActor(actor *Actor)

+ func (c *Collection) SetRequest(req *Request)

+ func (c *Collection) SetRequestFromHTTP(r *http.Request, comm CommunicationProto, status int)

+ func (c *Collection) StartEvent(name string, eventType EventType, severity Severity) *EventBuilder

+ type CommunicationProto string

+ const ProtoGRPC

+ const ProtoREST

+ const ProtoSOAP

+ const ProtoWebSocket

+ type Environment string

+ const Development

+ const Production

+ const Testing

+ type Event struct

+ DurationMs int

+ Errors []EventError

+ EventID string

+ Message string

+ Metadata map[string]any

+ Name string

+ ParentEventID *string

+ Severity Severity

+ Status Status

+ Timestamp time.Time

+ Type EventType

+ type EventBuilder struct

+ func (eb *EventBuilder) AddError(code, message string, stack *string) *EventBuilder

+ func (eb *EventBuilder) End()

+ func (eb *EventBuilder) WithMessage(msg string) *EventBuilder

+ func (eb *EventBuilder) WithMetadata(metadata map[string]any) *EventBuilder

+ func (eb *EventBuilder) WithParent(parentID string) *EventBuilder

+ type EventError struct

+ Code string

+ Message string

+ Stack *string

+ type EventType string

+ const TypeDatabase

+ const TypeExternalService

+ const TypeFunction

+ const TypeInternalService

+ type LogSchema struct

+ Actor *Actor

+ Environment Environment

+ Events []Event

+ Request *Request

+ SchemaVersion string

+ Service Service

+ Status Status

+ Time TimeInfo

+ TracingID string

+ type Request struct

+ Communication CommunicationProto

+ Method string

+ Route string

+ Status int

+ UserAgent string

+ type Service struct

+ Description *string

+ ID *string

+ Name string

+ Tags *[]string

+ Version string

+ type Severity string

+ const SeverityDebug

+ const SeverityError

+ const SeverityFatal

+ const SeverityInfo

+ const SeverityWarn

+ type Shipping struct

+ func NewShipping(bufferSize int, processLog func(LogSchema) error) *Shipping

+ func (s *Shipping) Close()

+ func (s *Shipping) Ship(log LogSchema)

+ type Status string

+ const StatusFailure

+ const StatusSuccess

+ type TimeInfo struct

+ CreatedAt time.Time

+ DurationMs int

+ FinishedAt time.Time

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