Documentation
¶
Overview ¶
Package cache stores values with a TTL behind a Store (memory, database; Redis in drivers/redis). Values are JSON-encoded, so typed reads use the generic functions:
user, err := cache.Remember(ctx, app.Cache, "user:42", time.Hour, func(ctx context.Context) (User, error) {
return orm.QueryOf[User](db).Find(ctx, 42)
})
Index ¶
- Variables
- func Get[T any](ctx context.Context, c *Cache, key string) (v T, ok bool, err error)
- func Remember[T any](ctx context.Context, c *Cache, key string, ttl time.Duration, ...) (T, error)
- type Cache
- func (c *Cache) Flush(ctx context.Context) error
- func (c *Cache) Forget(ctx context.Context, keys ...string) error
- func (c *Cache) Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
- func (c *Cache) NewLock(name string, ttl time.Duration) *Lock
- func (c *Cache) Put(ctx context.Context, key string, v any, ttl time.Duration) error
- func (c *Cache) Store() Store
- type Database
- func (d *Database) Add(ctx context.Context, key string, value []byte, ttl time.Duration) (bool, error)
- func (d *Database) CreateTable(ctx context.Context) error
- func (d *Database) Delete(ctx context.Context, keys ...string) error
- func (d *Database) DeleteIf(ctx context.Context, key string, value []byte) (bool, error)
- func (d *Database) Flush(ctx context.Context) error
- func (d *Database) Get(ctx context.Context, key string) ([]byte, bool, error)
- func (d *Database) Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
- func (d *Database) Prune(ctx context.Context) (int64, error)
- func (d *Database) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
- type Lock
- type Memory
- func (m *Memory) Add(_ context.Context, key string, value []byte, ttl time.Duration) (bool, error)
- func (m *Memory) Delete(_ context.Context, keys ...string) error
- func (m *Memory) DeleteIf(_ context.Context, key string, value []byte) (bool, error)
- func (m *Memory) Flush(context.Context) error
- func (m *Memory) Get(_ context.Context, key string) ([]byte, bool, error)
- func (m *Memory) Increment(_ context.Context, key string, delta int64, ttl time.Duration) (int64, error)
- func (m *Memory) Len() int
- func (m *Memory) Set(_ context.Context, key string, value []byte, ttl time.Duration) error
- type Store
Constants ¶
This section is empty.
Variables ¶
var ErrNotAcquired = errors.New("cache: lock not acquired")
ErrNotAcquired is returned by Lock.Block when the wait expired.
Functions ¶
func Remember ¶
func Remember[T any](ctx context.Context, c *Cache, key string, ttl time.Duration, fn func(ctx context.Context) (T, error), ) (T, error)
Remember returns the cached value or computes it with fn and stores it for ttl. Concurrent misses for the same key in this process run fn once (singleflight), so an expired hot key does not stampede the database.
Types ¶
type Cache ¶
type Cache struct {
// contains filtered or unexported fields
}
Cache is a Store with a key prefix, JSON encoding and stampede protection.
func (*Cache) Increment ¶
func (c *Cache) Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
Increment adds delta to the integer at key (counters, rate limits).
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
Database stores entries in a table (SQLite or Postgres): cache(key TEXT PRIMARY KEY, value TEXT NOT NULL, expires_at BIGINT) with expires_at in Unix milliseconds (0 = never). CreateTable creates it.
func NewDatabase ¶
NewDatabase returns a database store using table (default "cache").
func (*Database) Add ¶
func (d *Database) Add(ctx context.Context, key string, value []byte, ttl time.Duration) (bool, error)
Add implements Store: expired rows are replaced, live ones kept.
func (*Database) CreateTable ¶
CreateTable creates the cache table if missing.
func (*Database) Increment ¶
func (d *Database) Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
Increment implements Store (atomically, in a transaction).
type Lock ¶
type Lock struct {
// contains filtered or unexported fields
}
Lock is a distributed (store-wide) mutual exclusion lock.
type Memory ¶
type Memory struct {
// contains filtered or unexported fields
}
Memory is an in-process LRU store with TTLs. MaxEntries bounds memory (least recently used entries are evicted).
func (*Memory) Increment ¶
func (m *Memory) Increment(_ context.Context, key string, delta int64, ttl time.Duration) (int64, error)
Increment implements Store.
type Store ¶
type Store interface {
Get(ctx context.Context, key string) ([]byte, bool, error)
Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
// Add sets key only when it is absent (or expired) and reports whether
// it did; locks rely on it being atomic.
Add(ctx context.Context, key string, value []byte, ttl time.Duration) (bool, error)
Delete(ctx context.Context, keys ...string) error
// DeleteIf deletes key only when it holds value (lock release).
DeleteIf(ctx context.Context, key string, value []byte) (bool, error)
// Increment adds delta to an integer value (missing keys start at 0
// with ttl) and returns the new value.
Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
Flush(ctx context.Context) error
}
Store is a cache backend. Keys arrive already prefixed.
Source Files
Directories