Documentation
¶
Index ¶
Constants ¶
View Source
const ( KindExecuted = "executed" KindError = "error" KindRetry = "retry" KindCacheHit = "cache_hit" KindCacheMiss = "cache_miss" KindCanceled = "canceled" KindPanic = "panic" KindCoalesced = "coalesced" KindDeduplicated = "deduplicated" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MemorySink ¶
type MemorySink struct {
// contains filtered or unexported fields
}
func NewMemorySink ¶
func NewMemorySink(capacity int) *MemorySink
func (*MemorySink) Events ¶
func (s *MemorySink) Events() []Event
type MetricsSink ¶
type MetricsSink struct {
// contains filtered or unexported fields
}
MetricsSink aggregates lifecycle event counts in memory.
func NewMetricsSink ¶
func NewMetricsSink() *MetricsSink
NewMetricsSink creates an empty metrics sink.
func (*MetricsSink) Snapshot ¶
func (s *MetricsSink) Snapshot() map[MetricKey]uint64
Snapshot returns an isolated thread-safe copy of all counters.
type PrometheusSink ¶
type PrometheusSink struct {
// contains filtered or unexported fields
}
func NewPrometheusSink ¶
func NewPrometheusSink() *PrometheusSink
func (*PrometheusSink) Snapshot ¶
func (s *PrometheusSink) Snapshot() map[MetricKey]uint64
func (*PrometheusSink) WritePrometheus ¶
func (s *PrometheusSink) WritePrometheus(w io.Writer) error
type SlogSink ¶
type SlogSink struct {
// contains filtered or unexported fields
}
SlogSink writes structured lifecycle events to a standard-library slog.Logger.
func NewSlogSink ¶
NewSlogSink creates a sink using logger. If logger is nil, slog.Default() is used.
Click to show internal directories.
Click to hide internal directories.