kvs

Documentation

Index

• type KeyValueStore
  • func New(c Store) KeyValueStore
  • func (kvs KeyValueStore) Del(ctx context.Context, key ...string) error
  • func (kvs KeyValueStore) Get(ctx context.Context, key string, result any) error
  • func (kvs KeyValueStore) GetSet(ctx context.Context, key string, value any, ttl time.Duration, oldValue any) error
  • func (kvs KeyValueStore) Set(ctx context.Context, key string, value any, ttl time.Duration) error
• type RedisStore
  • func NewRedis(redis *redis.Client) RedisStore
  • func (r RedisStore) Del(ctx context.Context, keys ...string) error
  • func (r RedisStore) Get(ctx context.Context, key string) ([]byte, error)
  • func (r RedisStore) GetSet(ctx context.Context, key string, value []byte, ttl time.Duration) ([]byte, error)
  • func (r RedisStore) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
• type Store

Types

type KeyValueStore

type KeyValueStore struct {
	// contains filtered or unexported fields
}

func New

func New(c Store) KeyValueStore

func (KeyValueStore) Del

func (kvs KeyValueStore) Del(ctx context.Context, key ...string) error

func (KeyValueStore) Get

func (kvs KeyValueStore) Get(ctx context.Context, key string, result any) error

func (KeyValueStore) GetSet

func (kvs KeyValueStore) GetSet(ctx context.Context, key string, value any, ttl time.Duration, oldValue any) error

func (KeyValueStore) Set

func (kvs KeyValueStore) Set(ctx context.Context, key string, value any, ttl time.Duration) error

type RedisStore

type RedisStore struct {
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis(redis *redis.Client) RedisStore

func (RedisStore) Del

func (r RedisStore) Del(ctx context.Context, keys ...string) error

func (RedisStore) Get

func (r RedisStore) Get(ctx context.Context, key string) ([]byte, error)

func (RedisStore) GetSet

func (r RedisStore) GetSet(ctx context.Context, key string, value []byte, ttl time.Duration) ([]byte, error)

func (RedisStore) Set

func (r RedisStore) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

type Store

type Store interface {
	Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
	Get(ctx context.Context, key string) ([]byte, error)
	GetSet(ctx context.Context, key string, value []byte, ttl time.Duration) ([]byte, error)
	Del(ctx context.Context, key ...string) error
}