kvbitcask

Documentation

Index

• type BitcaskStore
  • func New[K, V kv.Bytes](path string, options ...bitcask.Option) (*BitcaskStore[K, V], error)
  • func (s *BitcaskStore[K, V]) Close(ctx context.Context) error
  • func (s *BitcaskStore[K, V]) Delete(ctx context.Context, k K) error
  • func (s *BitcaskStore[K, V]) Edit(ctx context.Context, k K, edit kv.Edit[V]) error
  • func (s *BitcaskStore[K, V]) Get(ctx context.Context, k K) (V, error)
  • func (s *BitcaskStore[K, V]) Range(ctx context.Context, iter kv.Iter[K, V]) error
  • func (s *BitcaskStore[K, V]) RangeWithPrefix(ctx context.Context, k K, iter kv.Iter[K, V]) error
  • func (s *BitcaskStore[K, V]) Set(ctx context.Context, k K, v V) error

Types

type BitcaskStore

type BitcaskStore[K, V kv.Bytes] struct {
	DB bitcask.DB
}

func New

func New[K, V kv.Bytes](path string, options ...bitcask.Option) (*BitcaskStore[K, V], error)

func (*BitcaskStore[K, V]) Close

func (s *BitcaskStore[K, V]) Close(ctx context.Context) error

func (*BitcaskStore[K, V]) Delete

func (s *BitcaskStore[K, V]) Delete(ctx context.Context, k K) error

func (*BitcaskStore[K, V]) Edit

func (s *BitcaskStore[K, V]) Edit(ctx context.Context, k K, edit kv.Edit[V]) error

func (*BitcaskStore[K, V]) Get

func (s *BitcaskStore[K, V]) Get(ctx context.Context, k K) (V, error)

Get implements kv.Store.

func (*BitcaskStore[K, V]) Range

func (s *BitcaskStore[K, V]) Range(ctx context.Context, iter kv.Iter[K, V]) error

func (*BitcaskStore[K, V]) RangeWithPrefix

func (s *BitcaskStore[K, V]) RangeWithPrefix(ctx context.Context, k K, iter kv.Iter[K, V]) error

RangeWithPrefix implements kv.Store.

func (*BitcaskStore[K, V]) Set

func (s *BitcaskStore[K, V]) Set(ctx context.Context, k K, v V) error

Set implements kv.Store.