cache

Jul 22, 2026

Changes in this version

+ type InvalidationQueue struct

+ func NewInvalidationQueue() *InvalidationQueue

+ func (q *InvalidationQueue) Add(keys ...string)

+ func (q *InvalidationQueue) Flush(ctx context.Context, client *redis.Client) error

+ func (q *InvalidationQueue) Keys() []string

+ type InvalidationRetrier struct

+ func NewInvalidationRetrier(client *redis.Client) *InvalidationRetrier

+ func (r *InvalidationRetrier) Enqueue(keys ...string)

type Option

+ func WithInvalidationQueue(queue *InvalidationQueue) Option

type Options

+ Invalidations *InvalidationQueue

May 23, 2026

Changes in this version

type CachedConn

+ func (cc CachedConn) GetCacheCtx(ctx context.Context, key string, v interface{}) error

+ func (cc CachedConn) SetCacheCtx(ctx context.Context, key string, v interface{}) error

Jun 1, 2025

Changes in this version

+ type Option func(o *Options)

+ func WithExpiry(expiry time.Duration) Option

+ func WithNotFoundExpiry(expiry time.Duration) Option

+ type Options struct

+ Expiry time.Duration

+ NotFoundExpiry time.Duration

Apr 25, 2025

Changes in this version

+ var ErrNotFound = redis.Nil

+ type Cache interface

+ Del func(keys ...string) error

+ DelCtx func(ctx context.Context, keys ...string) error

+ Get func(key string, val any) error

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

+ Set func(key string, val any) error

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

+ SetWithExpire func(key string, val any, expire time.Duration) error

+ SetWithExpireCtx func(ctx context.Context, key string, val any, expire time.Duration) error

+ type CachedConn struct

+ func NewConn(db *gorm.DB, c *redis.Client) CachedConn

+ func (cc CachedConn) DelCache(keys ...string) error

+ func (cc CachedConn) DelCacheCtx(ctx context.Context, keys ...string) error

+ func (cc CachedConn) ExecCtx(ctx context.Context, execCtx ExecCtxFn, keys ...string) error

+ func (cc CachedConn) ExecNoCache(exec ExecCtxFn) error

+ func (cc CachedConn) ExecNoCacheCtx(ctx context.Context, execCtx ExecCtxFn) (err error)

+ func (cc CachedConn) GetCache(key string, v interface{}) error

+ func (cc CachedConn) QueryCtx(ctx context.Context, v interface{}, key string, query QueryCtxFn) (err error)

+ func (cc CachedConn) QueryNoCacheCtx(ctx context.Context, v interface{}, query QueryCtxFn) (err error)

+ func (cc CachedConn) SetCache(key string, v interface{}) error

+ func (cc CachedConn) Transact(fn func(db *gorm.DB) error, opts ...*sql.TxOptions) error

+ func (cc CachedConn) TransactCtx(ctx context.Context, fn func(db *gorm.DB) error, opts ...*sql.TxOptions) error

+ type ExecCtxFn func(conn *gorm.DB) error

+ type IndexQueryCtxFn func(conn *gorm.DB, v interface{}) (interface{}, error)

+ type PrimaryQueryCtxFn func(conn *gorm.DB, v, primary interface{}) error

+ type QueryCtxFn func(conn *gorm.DB, v interface{}) error