Versions in this module Expand all Collapse all v0 v0.1.2 Nov 8, 2022 v0.1.1 Nov 4, 2022 Changes in this version + const StoreName + var ErrAbortTryLock = errors.New("redis: lock operation aborted") + var ErrMultipleEndpointsUnsupported = errors.New("redis: does not support multiple endpoints") + type Codec interface + Decode func(b []byte, kv *store.KVPair) error + Encode func(kv *store.KVPair) (string, error) + type Config struct + DB int + Password string + TLS *tls.Config + Username string + type JSONCodec struct + func (c JSONCodec) Decode(b []byte, kv *store.KVPair) error + func (c JSONCodec) Encode(kv *store.KVPair) (string, error) + type RawCodec struct + func (c RawCodec) Decode(b []byte, kv *store.KVPair) error + func (c RawCodec) Encode(kv *store.KVPair) (string, error) + type Store struct + func New(ctx context.Context, endpoints []string, options *Config) (*Store, error) + func NewWithCodec(ctx context.Context, endpoints []string, options *Config, codec Codec) (*Store, error) + func (r *Store) AtomicDelete(ctx context.Context, key string, previous *store.KVPair) (bool, error) + func (r *Store) AtomicPut(ctx context.Context, key string, value []byte, previous *store.KVPair, ...) (bool, *store.KVPair, error) + func (r *Store) Close() error + func (r *Store) Delete(ctx context.Context, key string) error + func (r *Store) DeleteTree(ctx context.Context, directory string) error + func (r *Store) Exists(ctx context.Context, key string, _ *store.ReadOptions) (bool, error) + func (r *Store) Get(ctx context.Context, key string, _ *store.ReadOptions) (*store.KVPair, error) + func (r *Store) List(ctx context.Context, directory string, _ *store.ReadOptions) ([]*store.KVPair, error) + func (r *Store) NewLock(_ context.Context, key string, opts *store.LockOptions) (store.Locker, error) + func (r *Store) Put(ctx context.Context, key string, value []byte, opts *store.WriteOptions) error + func (r *Store) Watch(ctx context.Context, key string, _ *store.ReadOptions) (<-chan *store.KVPair, error) + func (r *Store) WatchTree(ctx context.Context, directory string, _ *store.ReadOptions) (<-chan []*store.KVPair, error)
Go to main page