remember

README

remember

Documentation

Index

• Variables
• type KV
• type Leveldb
  • func NewLeveldb(DbPath string) *Leveldb
  • func (db *Leveldb) Delete(key []byte) (err error)
  • func (db *Leveldb) Get(key []byte) (value []byte, err error)
  • func (db *Leveldb) Put(key, value []byte) (err error)
• type Remember
  • func NewRemember(store KV) *Remember
  • func (r *Remember) Close() (err error)
  • func (r *Remember) Delete(key []byte) (err error)
  • func (r *Remember) Get(key []byte) (value []byte, err error)
  • func (r *Remember) KVEncodeKey(key []byte) (encodeKey []byte)
  • func (r *Remember) Lpop(key []byte) ([]byte, error)
  • func (r *Remember) Lpush(key, elVlaue []byte) error
  • func (r *Remember) Put(key, value []byte) (err error)
  • func (r *Remember) Rpop(key []byte) ([]byte, error)
  • func (r *Remember) Rpush(key, elVlaue []byte) error

Variables

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

Types

type KV

type KV interface {
	Get([]byte) ([]byte, error)
	Put([]byte, []byte) error
	Delete([]byte) error
	Close() error
}

type Leveldb

type Leveldb struct {
	*leveldb.DB
}

func NewLeveldb

func NewLeveldb(DbPath string) *Leveldb

func (*Leveldb) Delete

func (db *Leveldb) Delete(key []byte) (err error)

func (*Leveldb) Get

func (db *Leveldb) Get(key []byte) (value []byte, err error)

func (*Leveldb) Put

func (db *Leveldb) Put(key, value []byte) (err error)

type Remember

type Remember struct {
	Store KV
	sync.Mutex
}

func NewRemember

func NewRemember(store KV) *Remember

func (*Remember) Close

func (r *Remember) Close() (err error)

func (*Remember) Delete

func (r *Remember) Delete(key []byte) (err error)

func (*Remember) Get

func (r *Remember) Get(key []byte) (value []byte, err error)

func (*Remember) KVEncodeKey

func (r *Remember) KVEncodeKey(key []byte) (encodeKey []byte)

func (*Remember) Lpop

func (r *Remember) Lpop(key []byte) ([]byte, error)

func (*Remember) Lpush

func (r *Remember) Lpush(key, elVlaue []byte) error

func (*Remember) Put

func (r *Remember) Put(key, value []byte) (err error)

func (*Remember) Rpop

func (r *Remember) Rpop(key []byte) ([]byte, error)

func (*Remember) Rpush

func (r *Remember) Rpush(key, elVlaue []byte) error