cache

Documentation

Index

• func Bypass(ctx context.Context) context.Context
• func IsBypassed(ctx context.Context) bool
• type Cache
  • func New[K comparable, V any](client RedisClient, toKey func(K) string, onMiss fetch[K, V], ...) *Cache[K, V]
  • func (c *Cache[K, V]) EvictOnSuccess(ctx context.Context, item K, err error) error
  • func (c *Cache[K, V]) Get(ctx context.Context, id K) (V, error)
  • func (c *Cache[K, V]) List(ctx context.Context, onMissError func(K, error) bool, items ...K) (outputs []V, err error)
  • func (c *Cache[K, V]) Store(ctx context.Context, id K, value V) error
  • func (c *Cache[K, V]) WithExtendOnHit() *Cache[K, V]
  • func (c *Cache[K, V]) WithMaxConcurrency(concurrency int) *Cache[K, V]
  • func (c *Cache[K, V]) WithMissMany(cb fetchMany[K, V]) *Cache[K, V]
  • func (c *Cache[K, V]) WithRead(client RedisClient) *Cache[K, V]
  • func (c *Cache[K, V]) WithSerializer(serializer Serializer[V]) *Cache[K, V]
  • func (c *Cache[K, V]) WithTTL(ttl time.Duration) *Cache[K, V]
• type IndexedItems
  • func (ii IndexedItems[K]) Items() []K
• type JSONSerializer
  • func (JSONSerializer[V]) Decode(payload []byte) (V, error)
  • func (JSONSerializer[V]) Encode(payload V) ([]byte, error)
• type RedisClient
• type Serializer
• type StringSerializer
  • func (StringSerializer) Decode(payload []byte) (string, error)
  • func (StringSerializer) Encode(payload string) ([]byte, error)

Functions

func Bypass

func Bypass(ctx context.Context) context.Context

func IsBypassed

func IsBypassed(ctx context.Context) bool

Types

type Cache

type Cache[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 fetch[K, V], tracerProvider trace.TracerProvider) *Cache[K, V]

func (*Cache[K, V]) EvictOnSuccess

func (c *Cache[K, V]) EvictOnSuccess(ctx context.Context, item K, err error) error

func (*Cache[K, V]) Get

func (c *Cache[K, V]) Get(ctx context.Context, id K) (V, error)

func (*Cache[K, V]) List

func (c *Cache[K, V]) List(ctx context.Context, onMissError func(K, error) bool, items ...K) (outputs []V, err error)

If onMissError returns false, List stops by returning an error

func (*Cache[K, V]) Store

func (c *Cache[K, V]) Store(ctx context.Context, id K, value V) error

func (*Cache[K, V]) WithExtendOnHit

func (c *Cache[K, V]) WithExtendOnHit() *Cache[K, V]

func (*Cache[K, V]) WithMaxConcurrency

func (c *Cache[K, V]) WithMaxConcurrency(concurrency int) *Cache[K, V]

func (*Cache[K, V]) WithMissMany

func (c *Cache[K, V]) WithMissMany(cb fetchMany[K, V]) *Cache[K, V]

func (*Cache[K, V]) WithRead

func (c *Cache[K, V]) WithRead(client RedisClient) *Cache[K, V]

func (*Cache[K, V]) WithSerializer

func (c *Cache[K, V]) WithSerializer(serializer Serializer[V]) *Cache[K, V]

func (*Cache[K, V]) WithTTL

func (c *Cache[K, V]) WithTTL(ttl time.Duration) *Cache[K, V]

type IndexedItems

type IndexedItems[K comparable] map[K]int

func (IndexedItems[K]) Items

func (ii IndexedItems[K]) Items() []K

type JSONSerializer

type JSONSerializer[V any] struct{}

func (JSONSerializer[V]) Decode

func (JSONSerializer[V]) Decode(payload []byte) (V, error)

func (JSONSerializer[V]) Encode

func (JSONSerializer[V]) Encode(payload V) ([]byte, 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
	Pipeline() redis.Pipeliner
}

type Serializer

type Serializer[V any] interface {
	Encode(V) ([]byte, error)
	Decode([]byte) (V, error)
}

type StringSerializer

type StringSerializer struct{}

func (StringSerializer) Decode

func (StringSerializer) Decode(payload []byte) (string, error)

func (StringSerializer) Encode

func (StringSerializer) Encode(payload string) ([]byte, error)