store

Documentation

Index

• Variables
• func NewLevelDB(dir string) (*leveldbStore, error)
• type PrefixStore
  • func NewPrefixStore(store Store, prefix []byte) *PrefixStore
  • func (s *PrefixStore) Close() error
  • func (s *PrefixStore) Delete(key []byte) error
  • func (s *PrefixStore) DeleteAll() error
  • func (s *PrefixStore) Get(key []byte) ([]byte, error)
  • func (s *PrefixStore) Has(key []byte) (bool, error)
  • func (s *PrefixStore) ListAll() ([][]byte, error)
  • func (s *PrefixStore) ListAllKey() ([][]byte, error)
  • func (s *PrefixStore) Put(key []byte, value []byte) error
• type Store

Variables

var (
	ErrNotFound = errors.New("not found")
)

Functions

func NewLevelDB

func NewLevelDB(dir string) (*leveldbStore, error)

Types

type PrefixStore

type PrefixStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPrefixStore

func NewPrefixStore(store Store, prefix []byte) *PrefixStore

func (*PrefixStore) Close

func (s *PrefixStore) Close() error

func (*PrefixStore) Delete

func (s *PrefixStore) Delete(key []byte) error

func (*PrefixStore) DeleteAll

func (s *PrefixStore) DeleteAll() error

func (*PrefixStore) Get

func (s *PrefixStore) Get(key []byte) ([]byte, error)

func (*PrefixStore) Has

func (s *PrefixStore) Has(key []byte) (bool, error)

func (*PrefixStore) ListAll

func (s *PrefixStore) ListAll() ([][]byte, error)

func (*PrefixStore) ListAllKey

func (s *PrefixStore) ListAllKey() ([][]byte, error)

func (*PrefixStore) Put

func (s *PrefixStore) Put(key []byte, value []byte) error

type Store

type Store interface {
	io.Closer

	Get(key []byte) ([]byte, error)
	List(prefix []byte) (results [][]byte, err error)
	ListKey(prefix []byte) (results [][]byte, err error)

	Put(key, value []byte) error
	Delete(key []byte) error
	DeleteAll(prefix []byte) error

	Has(key []byte) (bool, error)

	Dir() string
}