cache

Documentation

Index

• func EvictOnSuccess(ctx context.Context, redisClient RedisClient, key string, err error) error
• type App
  • func New[K any, V any](client RedisClient, toKey func(K) string, ...) App[K, V]
  • func (a App[K, V]) Get(ctx context.Context, item K) (V, error)
  • func (a App[K, V]) List(ctx context.Context, concurrency uint64, items ...K) ([]V, error)
• type RedisClient

Functions

func EvictOnSuccess

func EvictOnSuccess(ctx context.Context, redisClient RedisClient, key string, err error) error

Types

type App

type App[K any, V any] struct {
	// contains filtered or unexported fields
}

func New

func New[K any, V any](client RedisClient, toKey func(K) string, onMiss func(context.Context, K) (V, error), ttl time.Duration) App[K, V]

func (App[K, V]) Get

func (a App[K, V]) Get(ctx context.Context, item K) (V, error)

func (App[K, V]) List

func (a App[K, V]) List(ctx context.Context, concurrency uint64, items ...K) ([]V, error)

type RedisClient

type RedisClient interface {
	Load(ctx context.Context, key string) ([]byte, error)
	LoadMany(ctx context.Context, keys ...string) ([]string, error)
	Store(ctx context.Context, key string, value any, ttl time.Duration) error
	Delete(ctx context.Context, keys ...string) error
}