Documentation
¶
Index ¶
- type Cache
- type MemoryCache
- func (m *MemoryCache) Close() error
- func (m *MemoryCache) Delete(ctx context.Context, key string) error
- func (m *MemoryCache) DeletePattern(ctx context.Context, pattern string) error
- func (m *MemoryCache) Exists(ctx context.Context, key string) (bool, error)
- func (m *MemoryCache) Get(ctx context.Context, key string) (interface{}, error)
- func (m *MemoryCache) Set(ctx context.Context, key string, value interface{}, ttl time.Duration) error
- type RedisCache
- func (r *RedisCache) Close() error
- func (r *RedisCache) Delete(ctx context.Context, key string) error
- func (r *RedisCache) DeletePattern(ctx context.Context, pattern string) error
- func (r *RedisCache) Exists(ctx context.Context, key string) (bool, error)
- func (r *RedisCache) Get(ctx context.Context, key string) (interface{}, error)
- func (r *RedisCache) Set(ctx context.Context, key string, value interface{}, ttl time.Duration) error
- type ShardedMemoryCache
- func (s *ShardedMemoryCache) Close() error
- func (s *ShardedMemoryCache) Delete(ctx context.Context, key string) error
- func (s *ShardedMemoryCache) DeletePattern(ctx context.Context, pattern string) error
- func (s *ShardedMemoryCache) Exists(ctx context.Context, key string) (bool, error)
- func (s *ShardedMemoryCache) Get(ctx context.Context, key string) (interface{}, error)
- func (s *ShardedMemoryCache) Set(ctx context.Context, key string, value interface{}, ttl time.Duration) error
- func (s *ShardedMemoryCache) ShardCount() int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cache ¶
type Cache interface {
Get(ctx context.Context, key string) (interface{}, error)
Set(ctx context.Context, key string, value interface{}, ttl time.Duration) error
Delete(ctx context.Context, key string) error
DeletePattern(ctx context.Context, pattern string) error
Exists(ctx context.Context, key string) (bool, error)
Close() error
}
Cache interface defines caching operations.
Two implementations are provided:
- MemoryCache: Simple in-process LRU cache with global TTL
- RedisCache: Distributed cache with per-item TTL support
Use MemoryCache for development and single-instance deployments. Use RedisCache for horizontal scaling or when per-item TTL is needed.
type MemoryCache ¶
type MemoryCache struct {
// contains filtered or unexported fields
}
MemoryCache implements an in-memory LRU cache. TTL is global, set at construction time via NewMemoryCache. For per-item TTL, use RedisCache instead.
func NewMemoryCache ¶
func NewMemoryCache(size int, ttl time.Duration) *MemoryCache
NewMemoryCache creates a new in-memory cache
func (*MemoryCache) Close ¶
func (m *MemoryCache) Close() error
Close closes the cache (no-op for memory cache)
func (*MemoryCache) Delete ¶
func (m *MemoryCache) Delete(ctx context.Context, key string) error
Delete removes a key from the cache
func (*MemoryCache) DeletePattern ¶
func (m *MemoryCache) DeletePattern(ctx context.Context, pattern string) error
DeletePattern removes all keys matching a pattern
type RedisCache ¶
type RedisCache struct {
// contains filtered or unexported fields
}
RedisCache implements a Redis-backed cache
func NewRedisCache ¶
func NewRedisCache(host string, port int, ttl time.Duration, poolSize int, minIdleConns int) (*RedisCache, error)
NewRedisCache creates a new Redis cache. poolSize and minIdleConns control the connection pool; zero values use defaults of 50 and 10 respectively.
func (*RedisCache) Delete ¶
func (r *RedisCache) Delete(ctx context.Context, key string) error
Delete removes a key from Redis
func (*RedisCache) DeletePattern ¶
func (r *RedisCache) DeletePattern(ctx context.Context, pattern string) error
DeletePattern removes all keys matching a pattern
type ShardedMemoryCache ¶
type ShardedMemoryCache struct {
// contains filtered or unexported fields
}
ShardedMemoryCache distributes keys across multiple MemoryCache shards to reduce lock contention under concurrent access. Each shard has its own LRU and its own mutex, so operations on keys that hash to different shards never contend.
The total capacity is size (spread across shards), and TTL is global.
func NewShardedMemoryCache ¶
func NewShardedMemoryCache(size int, ttl time.Duration, shardCount int) *ShardedMemoryCache
NewShardedMemoryCache creates a sharded in-memory cache. size is the total capacity (divided across shards). shardCount must be a power of two; if zero or invalid, defaults to 16.
func (*ShardedMemoryCache) Close ¶
func (s *ShardedMemoryCache) Close() error
Close purges all shards.
func (*ShardedMemoryCache) Delete ¶
func (s *ShardedMemoryCache) Delete(ctx context.Context, key string) error
Delete removes a key from the appropriate shard.
func (*ShardedMemoryCache) DeletePattern ¶
func (s *ShardedMemoryCache) DeletePattern(ctx context.Context, pattern string) error
DeletePattern removes all keys matching a prefix pattern across all shards.
func (*ShardedMemoryCache) Get ¶
func (s *ShardedMemoryCache) Get(ctx context.Context, key string) (interface{}, error)
Get retrieves a value from the appropriate shard.
func (*ShardedMemoryCache) Set ¶
func (s *ShardedMemoryCache) Set(ctx context.Context, key string, value interface{}, ttl time.Duration) error
Set stores a value in the appropriate shard.
func (*ShardedMemoryCache) ShardCount ¶
func (s *ShardedMemoryCache) ShardCount() int
ShardCount returns the number of shards (useful for diagnostics).
Source Files