cache

Documentation

Index

• func EvictOnSucces(ctx context.Context, client RedisClient, key string, err error) error
• func Load[V any](ctx context.Context, client RedisClient, key string, ...) (V, error)
• type App
  • func New[K comparable, V any](client RedisClient, toKey func(K) string, ...) App[K, V]
  • func (a App[K, V]) EvictOnSuccess(ctx context.Context, item K, err error) error
  • func (a App[K, V]) Get(ctx context.Context, id K) (V, error)
  • func (a App[K, V]) List(ctx context.Context, onMissError func(K, error) bool, items ...K) ([]V, error)
  • func (a App[K, V]) ListMany(ctx context.Context, fetchMany func(context.Context, []K) ([]V, error), ...) ([]V, error)
  • func (a App[K, V]) Store(ctx context.Context, id K, value V) error
• type RedisClient

Functions

func EvictOnSucces

func EvictOnSucces(ctx context.Context, client RedisClient, key string, err error) error

func Load

func Load[V any](ctx context.Context, client RedisClient, key string, onMiss func(context.Context) (V, error), ttl time.Duration) (V, error)

Types

type App

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

func New

func New[K comparable, V any](client RedisClient, toKey func(K) string, onMiss func(context.Context, K) (V, error), ttl time.Duration, concurrency uint64, tracer trace.Tracer) App[K, V]

func (App[K, V]) EvictOnSuccess

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

func (App[K, V]) Get

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

func (App[K, V]) List

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

If onMissError returns false, List stops by returning an error

func (App[K, V]) ListMany

func (a App[K, V]) ListMany(ctx context.Context, fetchMany func(context.Context, []K) ([]V, error), items ...K) ([]V, error)

Param fetchMany has to return the same number of values as requested and in the same order

func (App[K, V]) Store

func (a App[K, V]) Store(ctx context.Context, id K, value V) error

type RedisClient

type RedisClient interface {
	Enabled() bool
	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
	Expire(ctx context.Context, ttl time.Duration, keys ...string) error
}