redis

Documentation

Index

• type Cacher
  • func NewCache(cfg *c.Configuration, logger *slog.Logger) Cacher
• type RedisSubscriber

Types

type Cacher

type Cacher interface {
	Shutdown(ctx context.Context)
	Get(ctx context.Context, key string) ([]byte, error)
	Set(ctx context.Context, key string, val []byte) error
	SetWithExpiry(ctx context.Context, key string, val []byte, expiry time.Duration) error
	Delete(ctx context.Context, key string) error
	Publish(ctx context.Context, channelName string, binary []byte) error
	Subscribe(ctx context.Context, channelName string) RedisSubscriber
	GetRedisClient() redis.UniversalClient
}

func NewCache

func NewCache(cfg *c.Configuration, logger *slog.Logger) Cacher

type RedisSubscriber

type RedisSubscriber interface {
	WaitUntilReceiveMessage(ctx context.Context) ([]byte, error)
	Close() error
}