netkv

Documentation

Index

• func NewStore(dsnString string) (store.KVStore, error)
• type Store
  • func (s *Store) BatchDelete(ctx context.Context, keys [][]byte) (err error)
  • func (s *Store) BatchGet(ctx context.Context, keys [][]byte) *store.Iterator
  • func (s *Store) BatchPrefix(ctx context.Context, prefixes [][]byte, limitPerPrefix int, ...) *store.Iterator
  • func (s *Store) Close() error
  • func (s *Store) EnableEmpty()
  • func (s *Store) FlushPuts(ctx context.Context) error
  • func (s *Store) Get(ctx context.Context, key []byte) (value []byte, err error)
  • func (s *Store) Prefix(ctx context.Context, prefix []byte, limit int, options ...store.ReadOption) *store.Iterator
  • func (s *Store) Put(ctx context.Context, key, value []byte) (err error)
  • func (s *Store) Scan(ctx context.Context, start, exclusiveEnd []byte, limit int, ...) *store.Iterator
  • func (s *Store) String() string

Functions

func NewStore

func NewStore(dsnString string) (store.KVStore, error)

Types

type Store

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

func (*Store) BatchDelete

func (s *Store) BatchDelete(ctx context.Context, keys [][]byte) (err error)

func (*Store) BatchGet

func (s *Store) BatchGet(ctx context.Context, keys [][]byte) *store.Iterator

func (*Store) BatchPrefix

func (s *Store) BatchPrefix(ctx context.Context, prefixes [][]byte, limitPerPrefix int, options ...store.ReadOption) *store.Iterator

func (*Store) Close

func (s *Store) Close() error

func (*Store) EnableEmpty

func (s *Store) EnableEmpty()

func (*Store) FlushPuts

func (s *Store) FlushPuts(ctx context.Context) error

func (*Store) Get

func (s *Store) Get(ctx context.Context, key []byte) (value []byte, err error)

func (*Store) Prefix

func (s *Store) Prefix(ctx context.Context, prefix []byte, limit int, options ...store.ReadOption) *store.Iterator

func (*Store) Put

func (s *Store) Put(ctx context.Context, key, value []byte) (err error)

func (*Store) Scan

func (s *Store) Scan(ctx context.Context, start, exclusiveEnd []byte, limit int, options ...store.ReadOption) *store.Iterator

func (*Store) String

func (s *Store) String() string