leveldbstore

Documentation

Index

• type Batch
  • func (i *Batch) Commit() error
  • func (i *Batch) Delete(item storage.Item) error
  • func (i *Batch) Put(item storage.Item) error
• type Store
  • func New(path string, opts *opt.Options) (*Store, error)
  • func (s *Store) Batch(ctx context.Context) storage.Batch
  • func (s *Store) Close() (err error)
  • func (s *Store) Count(key storage.Key) (int, error)
  • func (s *Store) DB() *leveldb.DB
  • func (s *Store) Delete(item storage.Item) error
  • func (s *Store) Get(item storage.Item) error
  • func (s *Store) GetSize(k storage.Key) (int, error)
  • func (s *Store) Has(k storage.Key) (bool, error)
  • func (s *Store) Iterate(q storage.Query, fn storage.IterateFn) error
  • func (s *Store) Put(item storage.Item) error
• type Storer

Types

type Batch

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

func (*Batch) Commit

func (i *Batch) Commit() error

Commit implements storage.Batch interface Commit method.

func (*Batch) Delete

func (i *Batch) Delete(item storage.Item) error

Delete implements storage.Batch interface Delete method.

func (*Batch) Put

func (i *Batch) Put(item storage.Item) error

Put implements storage.Batch interface Put method.

type Store

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

func New

func New(path string, opts *opt.Options) (*Store, error)

New returns a new store the backed by leveldb. If path == "", the leveldb will run with in memory backend storage.

func (*Store) Batch

func (s *Store) Batch(ctx context.Context) storage.Batch

Batch implements storage.BatchedStore interface Batch method.

func (*Store) Close

func (s *Store) Close() (err error)

Close implements the storage.Store interface.

func (*Store) Count

func (s *Store) Count(key storage.Key) (int, error)

Count implements the storage.Store interface.

func (*Store) DB

func (s *Store) DB() *leveldb.DB

DB implements the Storer interface.

func (*Store) Delete

func (s *Store) Delete(item storage.Item) error

Delete implements the storage.Store interface.

func (*Store) Get

func (s *Store) Get(item storage.Item) error

Get implements the storage.Store interface.

func (*Store) GetSize

func (s *Store) GetSize(k storage.Key) (int, error)

GetSize implements the storage.Store interface.

func (*Store) Has

func (s *Store) Has(k storage.Key) (bool, error)

Has implements the storage.Store interface.

func (*Store) Iterate

func (s *Store) Iterate(q storage.Query, fn storage.IterateFn) error

Iterate implements the storage.Store interface.

func (*Store) Put

func (s *Store) Put(item storage.Item) error

Put implements the storage.Store interface.

type Storer

type Storer interface {
	DB() *leveldb.DB
}

Storer returns the underlying db store.