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
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

modecache

package module

Go to main page

Versions in this module

v1

v1.0.4

Dec 26, 2025

v1.0.3

Dec 4, 2025

v1.0.2

Nov 26, 2025

Changes in this version

+ func DeleteStore(ctx context.Context, store Store, key string) error

v1.0.1

Nov 26, 2025

Changes in this version

+ func GetStore[T any](ctx context.Context, store Store, key string) (T, int, error)

+ func SetStore[T any](ctx context.Context, store Store, key string, value T, ttl time.Duration) error

v1.0.0

Sep 18, 2025

Changes in this version

+ const KeepTTL

+ const Mutex128Shards

+ const SHadowKeyPrefix

+ var ErrKeyNonExistent = errors.New("modecache: key does not exist")

+ var ErrNil = errors.New("null pointer")

+ var ErrUnpackingFailed = errors.New("modecache: warp unpacking failed")

+ func GO(fn func())

+ func WrapForFirstIgnoreErrorWithTTL[T any](ctx context.Context, store Store, key string, ttl time.Duration, ...) (T, error)

+ func WrapForFirstIgnoreError[T any](ctx context.Context, name string, store Store, key string, query Query[T]) (T, error)

+ func WrapForReuseIgnoreErrorWithTTL[T any](ctx context.Context, store Store, key string, ttl time.Duration, ...) (T, error)

+ func WrapForReuseIgnoreError[T any](ctx context.Context, name string, store Store, key string, query Query[T]) (T, error)

+ func WrapWithTTL[T any](ctx context.Context, store Store, key string, ttl time.Duration, ...) (T, error)

+ func Wrap[T any](ctx context.Context, name string, store Store, key string, query Query[T]) (T, error)

+ type AbcBox struct

+ T T

+ Timestamp int

+ type CacheCtr struct

+ Name string

+ func NewCacheController[T any](name string, store Store, optionChain ...Option[T]) *CacheCtr[T]

+ func (c *CacheCtr[T]) GetStore(ctx context.Context, key string) (T, int, error)

+ func (c *CacheCtr[T]) SetStore(ctx context.Context, key string, value T, ttl time.Duration) error

+ func (c *CacheCtr[T]) Wrap(ctx context.Context, key string, query Query[T]) (p T, err error)

+ type CtxStorageKey struct

+ type LimitQueryPlugin struct

+ func (m *LimitQueryPlugin) InterceptCallCache(ctx context.Context, key string, loadCache LoadingForCache) (LoadingForCache, bool, error)

+ func (m *LimitQueryPlugin) InterceptCallQuery(ctx context.Context, key string, loadQuery LoadingForQuery) (LoadingForQuery, bool, error)

+ type LoadingForCache func(ctx context.Context, key string) (any, int, error)

+ type LoadingForQuery func(ctx context.Context, key string, ttl time.Duration) (any, error)

+ type MetricsPlugin struct

+ func (m *MetricsPlugin) InterceptCallCache(ctx context.Context, key string, loadCache LoadingForCache) (LoadingForCache, bool, error)

+ func (m *MetricsPlugin) InterceptCallQuery(ctx context.Context, key string, loadQuery LoadingForQuery) (LoadingForQuery, bool, error)

+ type Mutex128 struct

+ func (rw *Mutex128) Lock(shard uint)

+ func (rw *Mutex128) TryLock(shard uint) bool

+ func (rw *Mutex128) Unlock(shard uint)

+ type Option func(m *CacheCtr[T])

+ func WithPlugins[T any](p ...Plugin) Option[T]

+ func WithPolicy[T any](p Policy) Option[T]

+ type Plugin interface

+ InterceptCallCache func(ctx context.Context, key string, loadCache LoadingForCache) (LoadingForCache, bool, error)

+ InterceptCallQuery func(ctx context.Context, key string, loadQuery LoadingForQuery) (LoadingForQuery, bool, error)

+ func NewLimitQueryPlugin(r rate.Limit, b int) Plugin

+ func NewMetricsPlugin(name string) Plugin

+ type Policy func(ctx context.Context, key string, queryFormDB LoadingForQuery, ...) (any, error)

+ func EasyPloy(ttl time.Duration) Policy

+ func FirstCachePolyIgnoreError(expireTime time.Duration) Policy

+ func ReuseCachePloyIgnoreError(expireTime time.Duration) Policy

+ type Query func(context.Context) (T, error)

+ type RedisHashStore struct

+ func NewRedisHashStore(ctx context.Context, rd *redis.Client, rdsKey string, rdsHashKey string) (context.Context, *RedisHashStore)

+ func (r *RedisHashStore) Del(ctx context.Context, _ string) error

+ func (r *RedisHashStore) DelAll(ctx context.Context) error

+ func (r *RedisHashStore) Get(ctx context.Context, _ string) (any, error)

+ func (r *RedisHashStore) IsDirectStore() bool

+ func (r *RedisHashStore) Set(ctx context.Context, _ string, data any, ttl time.Duration) error

+ type SingleflightGroup struct

+ func (s *SingleflightGroup) Do(ctx context.Context, key string, fn func() (interface{}, error)) (v interface{}, err error, shared bool)

+ type Store interface

+ Del func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (any, error)

+ IsDirectStore func() bool

+ Set func(ctx context.Context, key string, data any, ttl time.Duration) error

+ func NewCacheStore(c *cache.Cache) Store

+ func NewRedisStore(rd *redis.Client) Store

+ type TaskResult struct

+ Key string

+ T T

+ TTL time.Duration

+ type TimerJobList func(ctx context.Context) ([]*TaskResult[T], error)