cache

Documentation

Index

• func Fetch[T any](cache Cacher, key string, expiration time.Duration, fn func() (T, error)) (T, error)
• func FetchArg[T any, A any](cache Cacher, key string, expiration time.Duration, fn func(a A) (T, error), ...) (T, error)
• func Key(args ...any) string
• type Cacher
  • func NewCache(ctx context.Context, conf *config.CacheConfig) Cacher
• type MemoryCache
  • func NewMemoryCache(size int) *MemoryCache
  • func (m *MemoryCache) Delete(keys ...string) error
  • func (m *MemoryCache) Get(key string, value any) error
  • func (m *MemoryCache) Set(key string, value any, expiration time.Duration) error
• type RedisCache
  • func NewRedisCache(ctx context.Context, client *redis.Client) *RedisCache
  • func (r *RedisCache) Delete(keys ...string) error
  • func (r *RedisCache) Get(key string, value any) error
  • func (r *RedisCache) Set(key string, value any, expiration time.Duration) error

Functions

func Fetch

func Fetch[T any](cache Cacher, key string, expiration time.Duration, fn func() (T, error)) (T, error)

func FetchArg

func FetchArg[T any, A any](
	cache Cacher,
	key string,
	expiration time.Duration,
	fn func(a A) (T, error), a A) (T, error)

func Key

func Key(args ...any) string

Types

type Cacher

type Cacher interface {
	Get(key string, value any) error
	Set(key string, value any, expiration time.Duration) error
	Delete(keys ...string) error
}

func NewCache

func NewCache(ctx context.Context, conf *config.CacheConfig) Cacher

type MemoryCache

type MemoryCache struct {
	// contains filtered or unexported fields
}

func NewMemoryCache

func NewMemoryCache(size int) *MemoryCache

func (*MemoryCache) Delete

func (m *MemoryCache) Delete(keys ...string) error

func (*MemoryCache) Get

func (m *MemoryCache) Get(key string, value any) error

func (*MemoryCache) Set

func (m *MemoryCache) Set(key string, value any, expiration time.Duration) error

type RedisCache

type RedisCache struct {
	// contains filtered or unexported fields
}

func NewRedisCache

func NewRedisCache(ctx context.Context, client *redis.Client) *RedisCache

func (*RedisCache) Delete

func (r *RedisCache) Delete(keys ...string) error

func (*RedisCache) Get

func (r *RedisCache) Get(key string, value any) error

func (*RedisCache) Set

func (r *RedisCache) Set(key string, value any, expiration time.Duration) error