Versions in this module Expand all Collapse all v0 v0.5.1 Mar 30, 2022 v0.5.0 Mar 30, 2022 Changes in this version + func New(endpoints []string, options *store.Config) (store.Store, error) + type Lock struct + func (l *Lock) Lock(_ context.Context, stopCh chan struct{}) (<-chan struct{}, error) + func (l *Lock) Unlock(_ context.Context) error + type Mock struct + Endpoints []string + Options *store.Config + func (s *Mock) AtomicDelete(_ context.Context, key string, previous *store.KVPair) (bool, error) + func (s *Mock) AtomicPut(_ context.Context, key string, value []byte, previous *store.KVPair, ...) (bool, *store.KVPair, error) + func (s *Mock) Close() error + func (s *Mock) Delete(_ context.Context, key string) error + func (s *Mock) DeleteTree(_ context.Context, prefix string) error + func (s *Mock) Exists(_ context.Context, key string, opts *store.ReadOptions) (bool, error) + func (s *Mock) Get(_ context.Context, key string, opts *store.ReadOptions) (*store.KVPair, error) + func (s *Mock) List(_ context.Context, prefix string, opts *store.ReadOptions) ([]*store.KVPair, error) + func (s *Mock) NewLock(_ context.Context, key string, options *store.LockOptions) (store.Locker, error) + func (s *Mock) Put(_ context.Context, key string, value []byte, opts *store.WriteOptions) error + func (s *Mock) Watch(_ context.Context, key string, stopCh <-chan struct{}, opts *store.ReadOptions) (<-chan *store.KVPair, error) + func (s *Mock) WatchTree(_ context.Context, prefix string, stopCh <-chan struct{}, ...) (<-chan []*store.KVPair, error)
Go to main page