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

v0

v0.4.0

Sep 6, 2026

Changes in this version

+ type AddonFetchOutcome struct

+ Count uint64

+ Outcome string

+ type AddonFetchStats struct

+ Count uint64

+ Outcomes []AddonFetchOutcome

+ P99 time.Duration

+ P99Seconds float64

+ Refused uint64

+ Sum time.Duration

+ SumSeconds float64

+ func (f AddonFetchStats) Observed() bool

+ type AddonKills struct

+ Call uint64

+ Instantiate uint64

+ func (k AddonKills) Total() uint64

+ type AddonPerformance struct

+ Classes []AddonRedirectStats

+ Fetch AddonFetchStats

+ Kills AddonKills

+ func (p AddonPerformance) IsZero() bool

+ func (p AddonPerformance) Observed() bool

+ type AddonRedirectStats struct

+ Class string

+ Count uint64

+ P99 time.Duration

+ P99Seconds float64

+ Sum time.Duration

+ SumSeconds float64

type Metrics

+ func (m *Metrics) AddonPerformance() map[string]AddonPerformance

+ func (m *Metrics) ForgetAddon(addon, version string, abiVersion int, failureClass, permissions string)

+ func (m *Metrics) ObserveAddonFetch(addon, outcome string, d time.Duration)

+ func (m *Metrics) ObserveAddonLoad(addon, outcome string)

+ func (m *Metrics) ObserveAddonRedirect(addon, class string, d time.Duration)

+ func (m *Metrics) ObserveAddonRedirectKill(addon, step string)

+ func (m *Metrics) ObserveAddonRefusal(addon, permission string)

+ func (m *Metrics) SetAddonInfo(addon, version string, abiVersion int, failureClass, permissions string)

+ func (m *Metrics) SetAddonLargeObjects(addon string, n int64)

+ func (m *Metrics) SetAddonSchemaBytes(addon string, n int64)

v0.3.0

Aug 18, 2026

v0.2.0

Aug 6, 2026

Changes in this version

+ func SetWebPaths(paths []string)

type LimiterStats

+ Fallbacks func() int64

type Metrics

+ func (m *Metrics) ObserveAutomationFiring(trigger, outcome string)

+ func (m *Metrics) ObserveFeedCheck(result string)

+ func (m *Metrics) ObserveWebhookDelivery(outcome, status string)

+ func (m *Metrics) SetAuditLogBytes(n int64)

+ func (m *Metrics) SetJobStaleness(job string, seconds float64)

v0.1.0

Jul 31, 2026

Changes in this version

+ func ContextWithLogger(ctx context.Context, l *slog.Logger) context.Context

+ func LoggerFrom(ctx context.Context) *slog.Logger

+ func NewIngestCollector(stats IngestStats) prometheus.Collector

+ func NewLimiterCollector(limiters map[string]LimiterStats) prometheus.Collector

+ func NewLogger(c config.Config, w *os.File) *slog.Logger

+ func NewPoolCollector(pools map[string]*pgxpool.Pool) prometheus.Collector

+ type IngestStats interface

+ Counters func() (enqueued, dropped, flushed, failed, batches int64)

+ QueueDepth func() int

+ type LimiterStats interface

+ Len func() int

+ Overflows func() int64

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func (m *Metrics) Gather() *prometheus.Registry

+ func (m *Metrics) HTTPMiddleware(next http.Handler) http.Handler

+ func (m *Metrics) Handler() http.Handler

+ func (m *Metrics) ObserveJob(job string, err error)

+ func (m *Metrics) ObserveJobSkipped(job string)

+ func (m *Metrics) ObserveRedirect(outcome, cache string, d time.Duration)

+ func (m *Metrics) ObserveThrottled(limit string)

+ func (m *Metrics) Register(c prometheus.Collector)

+ type Surface string

+ const SurfaceAPI

+ const SurfaceOps

+ const SurfaceRedirect

+ const SurfaceStatic

+ const SurfaceWeb

+ func ClassifySurface(path string) Surface