mavl

Documentation

Index

• func DisableLog()
• func New(cfg *types.Store, sub []byte) queue.Module
• func SetLogLevel(level string)
• type Store
  • func (mavls *Store) Close()
  • func (mavls *Store) Commit(req *types.ReqHash) ([]byte, error)
  • func (mavls *Store) Del(req *types.StoreDel) ([]byte, error)
  • func (mavls *Store) Get(datas *types.StoreGet) [][]byte
  • func (mavls *Store) IterateRangeByStateHash(statehash []byte, start []byte, end []byte, ascending bool, ...)
  • func (mavls *Store) MemSet(datas *types.StoreSet, sync bool) ([]byte, error)
  • func (mavls *Store) ProcEvent(msg queue.Message)
  • func (mavls *Store) Rollback(req *types.ReqHash) ([]byte, error)
  • func (mavls *Store) Set(datas *types.StoreSet, sync bool) ([]byte, error)

Functions

func DisableLog

func DisableLog()

func New

func New(cfg *types.Store, sub []byte) queue.Module

func SetLogLevel

func SetLogLevel(level string)

Types

type Store

type Store struct {
	*drivers.BaseStore
	// contains filtered or unexported fields
}

func (*Store) Close

func (mavls *Store) Close()

func (*Store) Commit

func (mavls *Store) Commit(req *types.ReqHash) ([]byte, error)

func (*Store) Del

func (mavls *Store) Del(req *types.StoreDel) ([]byte, error)

func (*Store) Get

func (mavls *Store) Get(datas *types.StoreGet) [][]byte

func (*Store) IterateRangeByStateHash

func (mavls *Store) IterateRangeByStateHash(statehash []byte, start []byte, end []byte, ascending bool, fn func(key, value []byte) bool)

func (*Store) MemSet

func (mavls *Store) MemSet(datas *types.StoreSet, sync bool) ([]byte, error)

func (*Store) ProcEvent

func (mavls *Store) ProcEvent(msg queue.Message)

func (*Store) Rollback

func (mavls *Store) Rollback(req *types.ReqHash) ([]byte, error)

func (*Store) Set

func (mavls *Store) Set(datas *types.StoreSet, sync bool) ([]byte, error)