kvmvccdb

Documentation

Index

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

Variables

var (
	//ErrStateHashLost means err happened when query with StateHash
	ErrStateHashLost = errors.New("ErrStateHashLost")
)

Functions

func DisableLog

func DisableLog()

DisableLog disable log output

func New

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

New construct KVMVCCStore module

func SetLogLevel

func SetLogLevel(level string)

SetLogLevel set log level

Types

type KVMVCCStore

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

KVMVCCStore provide kvmvcc store interface implementation

func (*KVMVCCStore) Close

func (mvccs *KVMVCCStore) Close()

Close the KVMVCCStore module

func (*KVMVCCStore) Commit

func (mvccs *KVMVCCStore) Commit(req *types.ReqHash) ([]byte, error)

Commit kvs in the mem of KVMVCCStore module to state db and return the StateHash

func (*KVMVCCStore) CommitUpgrade

func (mvccs *KVMVCCStore) CommitUpgrade(req *types.ReqHash) ([]byte, error)

CommitUpgrade kvs in the mem of KVMVCCStore module to state db and return the StateHash

func (*KVMVCCStore) Del

func (mvccs *KVMVCCStore) Del(req *types.StoreDel) ([]byte, error)

Del set kvs to nil with StateHash

func (*KVMVCCStore) Get

func (mvccs *KVMVCCStore) Get(datas *types.StoreGet) [][]byte

Get kvs with statehash from KVMVCCStore

func (*KVMVCCStore) IterateRangeByStateHash

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

IterateRangeByStateHash travel with Prefix by StateHash to get the latest version kvs.

func (*KVMVCCStore) MemSet

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

MemSet set kvs to the mem of KVMVCCStore module and return the StateHash

func (*KVMVCCStore) MemSetUpgrade

func (mvccs *KVMVCCStore) MemSetUpgrade(datas *types.StoreSet, sync bool) ([]byte, error)

MemSetUpgrade set kvs to the mem of KVMVCCStore module and return the StateHash

func (*KVMVCCStore) ProcEvent

func (mvccs *KVMVCCStore) ProcEvent(msg *queue.Message)

ProcEvent handles supported events

func (*KVMVCCStore) Rollback

func (mvccs *KVMVCCStore) Rollback(req *types.ReqHash) ([]byte, error)

Rollback kvs in the mem of KVMVCCStore module and return the StateHash

func (*KVMVCCStore) Set

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

Set kvs with statehash to KVMVCCStore