mpt

Documentation

Index

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

Functions

func DisableLog

func DisableLog()

DisableLog disable log

func New

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

New new mpt store module

func SetLogLevel

func SetLogLevel(level string)

SetLogLevel set log level

Types

type Store

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

Store mpt store struct

func (*Store) Close

func (mpts *Store) Close()

Close close mpt store

func (*Store) Commit

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

Commit convert memcory mpt to storage db

func (*Store) Del

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

Del ...

func (*Store) Get

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

Get get values by keys

func (*Store) IterateRangeByStateHash

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

IterateRangeByStateHash 迭代实现功能； statehash：当前状态hash, start：开始查找的key, end: 结束的key, ascending：升序，降序, fn 迭代回调函数

func (*Store) MemSet

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

MemSet set keys values to memcory mpt, return root hash and error

func (*Store) ProcEvent

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

ProcEvent not support message

func (*Store) Rollback

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

Rollback 回退将缓存的mpt树删除掉

func (*Store) Set

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

Set set k v to mpt store db; sync is true represent write sync