cache

Documentation

Index

• type App
  • func New[K any, 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]) Store(ctx context.Context, id K, value V) error
• type RedisClient

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, 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]) Store

func (a App[K, V]) Store(ctx context.Context, id K, value 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
}