entitycache

Aug 15, 2026

Changes in this version

+ var ErrLoadInvalidated = errors.New("entitycache: load invalidated")

type EntityCache

+ Clear func()

type FullCache

+ func (c *FullCache[K, V]) Clear()

type LRUCache

+ func (c *LRUCache[K, V]) Clear()

+ func (c *LRUCache[K, V]) MutationEpoch() uint64

+ func (c *LRUCache[K, V]) SetIfMutationEpoch(epoch uint64, key K, value V) bool

+ type MutationEpochCache interface

+ MutationEpoch func() uint64

+ SetIfMutationEpoch func(epoch uint64, key K, value V) bool

Jul 18, 2026

Changes in this version

+ var ErrLoadLimitReached = errors.New("entitycache: concurrent load limit reached")

type Config

+ Lifecycle *Lifecycle

+ MaxConcurrentLoads int

+ type Lifecycle struct

+ func NewLifecycle() *Lifecycle

+ func (l *Lifecycle) Close()

+ func (l *Lifecycle) Context() context.Context

+ func (l *Lifecycle) Done() <-chan struct{}

+ func (l *Lifecycle) Go(run func(context.Context)) bool

+ func (l *Lifecycle) GoLoad(run func(context.Context)) bool

+ func (l *Lifecycle) GoRefresh(run func(context.Context)) bool

+ func (l *Lifecycle) ResourceCounts() (loads, refreshes int64)

type Refresher

+ func NewRefresherWithLifecycle[K comparable, V any](load Loader[K, V], cfg func() RefreshConfig, lifecycle *Lifecycle) *Refresher[K, V]

Jun 7, 2026

Changes in this version

type Config

+ Refresh func() RefreshConfig

+ type RefreshConfig struct

+ LoadTimeout time.Duration

+ RefreshAfter time.Duration

+ RefreshBackoffBase time.Duration

+ RefreshBackoffMax time.Duration

+ RefreshMaxRetries int

+ RefreshTimeout time.Duration

+ type RefreshOutcome int

+ const RefreshGone

+ const RefreshOK

+ const RefreshUnavailable

+ type Refresher struct

+ func NewRefresher[K comparable, V any](load Loader[K, V], cfg func() RefreshConfig) *Refresher[K, V]

+ func (r *Refresher[K, V]) TriggerRefresh(key K, handler func(RefreshOutcome, V))

May 30, 2026

Changes in this version

type Stats

+ Invalidations int64

+ LoadErrors int64

May 16, 2026

Changes in this version

+ var ErrNotFound = errors.New("entity not found")

+ type Action int

+ const ActionDelete

+ const ActionSet

+ type Config struct

+ Capacity int

+ Loader Loader[K, V]

+ NegativeTTL time.Duration

+ Now func() time.Time

+ OnEvict func(key K, value V)

+ type EntityCache interface

+ Apply func(action Action, key K, value V)

+ Delete func(key K)

+ Get func(ctx context.Context, key K) (V, bool, error)

+ Len func() int

+ Peek func(key K) (V, bool)

+ Range func(func(K, V) bool)

+ Set func(key K, value V)

+ Stats func() Stats

+ type FullCache struct

+ func NewFullCache[K comparable, V any]() *FullCache[K, V]

+ func (c *FullCache[K, V]) Apply(action Action, key K, value V)

+ func (c *FullCache[K, V]) Delete(key K)

+ func (c *FullCache[K, V]) Get(_ context.Context, key K) (V, bool, error)

+ func (c *FullCache[K, V]) Len() int

+ func (c *FullCache[K, V]) Peek(key K) (V, bool)

+ func (c *FullCache[K, V]) Range(fn func(K, V) bool)

+ func (c *FullCache[K, V]) Set(key K, value V)

+ func (c *FullCache[K, V]) Stats() Stats

+ type LRUCache struct

+ func NewLRUCache[K comparable, V any](cfg Config[K, V]) (*LRUCache[K, V], error)

+ func (c *LRUCache[K, V]) Apply(action Action, key K, value V)

+ func (c *LRUCache[K, V]) Delete(key K)

+ func (c *LRUCache[K, V]) Get(ctx context.Context, key K) (V, bool, error)

+ func (c *LRUCache[K, V]) Len() int

+ func (c *LRUCache[K, V]) Peek(key K) (V, bool)

+ func (c *LRUCache[K, V]) Range(fn func(K, V) bool)

+ func (c *LRUCache[K, V]) Set(key K, value V)

+ func (c *LRUCache[K, V]) Stats() Stats

+ type Loader interface

+ Load func(ctx context.Context, key K) (V, error)

+ type LoaderFunc func(context.Context, K) (V, error)

+ func (f LoaderFunc[K, V]) Load(ctx context.Context, k K) (V, error)

+ type Stats struct

+ Capacity int

+ Evictions int64

+ Hits int64

+ Misses int64

+ NegativeHits int64

+ Size int