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

state

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 28, 2026

Changes in this version

type Deduper

+ Release func(ctx context.Context, eventID string) error

v0.1.0

May 12, 2026

Changes in this version

+ type Cache interface

+ Repopulate func(ctx context.Context, src Store[V], keys []Key) error

+ func NewInstrumentedCache[V any](inner Cache[V], recorder metrics.Recorder, label string) Cache[V]

+ type Deduper interface

+ Close func() error

+ MarkSeen func(ctx context.Context, eventID string) (firstSeen bool, err error)

+ type Instrumented struct

+ func (s *Instrumented[V]) Close() error

+ func (s *Instrumented[V]) Get(ctx context.Context, k Key) (V, bool, error)

+ func (s *Instrumented[V]) GetMany(ctx context.Context, ks []Key) ([]V, []bool, error)

+ func (s *Instrumented[V]) MergeUpdate(ctx context.Context, k Key, delta V, ttl time.Duration) error

+ type InstrumentedCache struct

+ func (c *InstrumentedCache[V]) Close() error

+ func (c *InstrumentedCache[V]) Get(ctx context.Context, k Key) (V, bool, error)

+ func (c *InstrumentedCache[V]) GetMany(ctx context.Context, ks []Key) ([]V, []bool, error)

+ func (c *InstrumentedCache[V]) MergeUpdate(ctx context.Context, k Key, delta V, ttl time.Duration) error

+ func (c *InstrumentedCache[V]) Repopulate(ctx context.Context, src Store[V], keys []Key) error

+ type Key struct

+ Bucket int64

+ Entity string

+ type OnMergeFunc func(ctx context.Context, key Key, delta V) error

+ type OnMergeOption func(*onMergeConfig)

+ func WithHookErrorPropagation(propagate bool) OnMergeOption

+ func WithHookLogger(logger *slog.Logger) OnMergeOption

+ type Store interface

+ Close func() error

+ Get func(ctx context.Context, k Key) (val V, ok bool, err error)

+ GetMany func(ctx context.Context, ks []Key) (vals []V, ok []bool, err error)

+ MergeUpdate func(ctx context.Context, k Key, delta V, ttl time.Duration) error

+ func NewInstrumented[V any](inner Store[V], recorder metrics.Recorder, label string) Store[V]

+ func WithOnMerge[V any](inner Store[V], fn OnMergeFunc[V], opts ...OnMergeOption) Store[V]