Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

observability

package

Go to main page

Versions in this module

v2

v2.0.2

Aug 25, 2026

v2.0.1

Aug 25, 2026

Changes in this version

+ const DefaultAuditQueueSize

+ const DefaultAuditTimeout

+ var ErrAuditDropped = errors.New("audit event dropped")

+ var ErrInvalidAudit = errors.New("invalid audit event")

+ type AuditDispatcher struct

+ func NewAuditDispatcher(store AuditLogStore, queueSize int, timeout time.Duration) (*AuditDispatcher, error)

+ func (d *AuditDispatcher) Append(entry AuditLogEntry) error

+ func (d *AuditDispatcher) Close(ctx context.Context) error

+ func (d *AuditDispatcher) Stats() AuditDispatcherStats

+ type AuditDispatcherStats struct

+ Dropped uint64

+ Failed uint64

+ Rejected uint64

v2.0.0

Jul 19, 2026

Changes in this version

+ func AppendAudit(audits AuditLogStore, actor, action, target string, metadata map[string]any)

+ func Middleware(eventLogs EventLogStore, metrics MetricsStore) middleware.Middleware

+ type AuditLogEntry struct

+ Action string

+ Actor string

+ CreatedAt time.Time

+ Metadata map[string]any

+ Target string

+ type AuditLogQuery struct

+ Action string

+ Actor string

+ Limit int

+ Offset int

+ Target string

+ type AuditLogStore interface

+ AppendAudit func(ctx context.Context, entry AuditLogEntry) error

+ ListAudit func(ctx context.Context, query AuditLogQuery) ([]AuditLogEntry, error)

+ type EventLogEntry struct

+ ChatID string

+ Command string

+ CreatedAt time.Time

+ DurationMS int64

+ Error string

+ ID string

+ Payload string

+ Platform string

+ Text string

+ Type string

+ UserID string

+ type EventLogQuery struct

+ ChatID string

+ HasError *bool

+ Limit int

+ Offset int

+ Platform string

+ Type string

+ UserID string

+ type EventLogStore interface

+ AppendEvent func(ctx context.Context, entry EventLogEntry) error

+ ListEvents func(ctx context.Context, query EventLogQuery) ([]EventLogEntry, error)

+ type InMemory struct

+ func NewInMemory(capacity int) *InMemory

+ func (m *InMemory) AppendAudit(ctx context.Context, entry AuditLogEntry) error

+ func (m *InMemory) AppendEvent(ctx context.Context, entry EventLogEntry) error

+ func (m *InMemory) ListAudit(ctx context.Context, query AuditLogQuery) ([]AuditLogEntry, error)

+ func (m *InMemory) ListEvents(ctx context.Context, query EventLogQuery) ([]EventLogEntry, error)

+ func (m *InMemory) Observe(duration time.Duration, hasError bool, at time.Time)

+ func (m *InMemory) Snapshot(ctx context.Context) (MetricsSnapshot, error)

+ type MetricsSnapshot struct

+ AverageLatencyMS int64

+ ErrorsTotal int64

+ EventsTotal int64

+ LastEventAt time.Time

+ type MetricsStore interface

+ Observe func(duration time.Duration, hasError bool, at time.Time)

+ Snapshot func(ctx context.Context) (MetricsSnapshot, error)

+ type Postgres struct

+ func NewPostgres(pool *pgxpool.Pool) *Postgres

+ func (p *Postgres) AppendAudit(ctx context.Context, entry AuditLogEntry) error

+ func (p *Postgres) AppendEvent(ctx context.Context, entry EventLogEntry) error

+ func (p *Postgres) EnsureSchema(ctx context.Context) error

+ func (p *Postgres) ListAudit(ctx context.Context, query AuditLogQuery) ([]AuditLogEntry, error)

+ func (p *Postgres) ListEvents(ctx context.Context, query EventLogQuery) ([]EventLogEntry, error)

+ func (p *Postgres) Observe(duration time.Duration, hasError bool, at time.Time)

+ func (p *Postgres) Snapshot(ctx context.Context) (MetricsSnapshot, error)

Other modules containing this package

github.com/andrewkydev/astraengine