executor

Documentation

Overview

Package executor 实现执行器模块基类功能

Index

• func AddMVCC(db dbm.KVDB, detail *types.BlockDetail) (kvlist []*types.KeyValue)
• func DelMVCC(db dbm.KVDB, detail *types.BlockDetail) (kvlist []*types.KeyValue)
• func DisableLog()
• func GetStack() string
• func NewLocalDB(cli queue.Client, api client.QueueProtocolAPI, readOnly bool) db.KVDB
• func NewStateDB(client queue.Client, stateHash []byte, localdb db.KVDB, opt *StateDBOption) db.KV
• func RegisterPlugin(name string, p plugin)
• func SetLogLevel(level string)
• type Executor
  • func New(cfg *typ.ChainConfig) *Executor
  • func (exec *Executor) Close()
  • func (exec *Executor) SetQueueClient(qcli queue.Client)
  • func (exec *Executor) Wait()
• type LocalDB
  • func (l *LocalDB) Begin()
  • func (l *LocalDB) Close() error
  • func (l *LocalDB) Commit() error
  • func (l *LocalDB) DisableRead()
  • func (l *LocalDB) DisableWrite()
  • func (l *LocalDB) EnableRead()
  • func (l *LocalDB) EnableWrite()
  • func (l *LocalDB) Get(key []byte) ([]byte, error)
  • func (l *LocalDB) GetSetKeys() (keys []string)
  • func (l *LocalDB) List(prefix, key []byte, count, direction int32) ([][]byte, error)
  • func (l *LocalDB) PrefixCount(prefix []byte) (count int64)
  • func (l *LocalDB) ResetCache()
  • func (l *LocalDB) Rollback()
  • func (l *LocalDB) Set(key []byte, value []byte) error
  • func (l *LocalDB) StartTx()
• type StateDB
  • func (s *StateDB) BatchGet(keys [][]byte) (values [][]byte, err error)
  • func (s *StateDB) Begin()
  • func (s *StateDB) Commit() error
  • func (s *StateDB) Get(key []byte) ([]byte, error)
  • func (s *StateDB) GetSetKeys() (keys []string)
  • func (s *StateDB) ResetCache()
  • func (s *StateDB) Rollback()
  • func (s *StateDB) Set(key []byte, value []byte) error
  • func (s *StateDB) StartTx()
• type StateDBOption

Functions

func AddMVCC

func AddMVCC(db dbm.KVDB, detail *types.BlockDetail) (kvlist []*types.KeyValue)

AddMVCC convert key value to mvcc kv data

func DelMVCC

func DelMVCC(db dbm.KVDB, detail *types.BlockDetail) (kvlist []*types.KeyValue)

DelMVCC convert key value to mvcc kv data

func DisableLog

func DisableLog()

DisableLog disable log

func GetStack

func GetStack() string

GetStack ...

func NewLocalDB

func NewLocalDB(cli queue.Client, api client.QueueProtocolAPI, readOnly bool) db.KVDB

NewLocalDB 创建一个新的LocalDB

func NewStateDB

func NewStateDB(client queue.Client, stateHash []byte, localdb db.KVDB, opt *StateDBOption) db.KV

NewStateDB new state db

func RegisterPlugin

func RegisterPlugin(name string, p plugin)

RegisterPlugin register plugin

func SetLogLevel

func SetLogLevel(level string)

SetLogLevel set log level

Types

type Executor

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

Executor executor struct

func New

func New(cfg *typ.ChainConfig) *Executor

New new executor

func (*Executor) Close

func (exec *Executor) Close()

Close close executor

func (*Executor) SetQueueClient

func (exec *Executor) SetQueueClient(qcli queue.Client)

SetQueueClient set client queue, for recv msg

func (*Executor) Wait

func (exec *Executor) Wait()

Wait Executor ready

type LocalDB

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

LocalDB 本地数据库，类似localdb，不加入区块链的状态。 数据库只读，不能落盘 数据的get set 主要经过 cache 如果需要进行list, 那么把get set 的内容加入到 后端数据库

func (*LocalDB) Begin

func (l *LocalDB) Begin()

Begin 开始一个事务

func (*LocalDB) Close

func (l *LocalDB) Close() error

Close 提交一个事务

func (*LocalDB) Commit

func (l *LocalDB) Commit() error

Commit 提交一个事务

func (*LocalDB) DisableRead

func (l *LocalDB) DisableRead()

DisableRead 禁止读取LocalDB数据库

func (*LocalDB) DisableWrite

func (l *LocalDB) DisableWrite()

DisableWrite 禁止写LocalDB数据库

func (*LocalDB) EnableRead

func (l *LocalDB) EnableRead()

EnableRead 启动读取LocalDB数据库

func (*LocalDB) EnableWrite

func (l *LocalDB) EnableWrite()

EnableWrite 启动写LocalDB数据库

func (*LocalDB) Get

func (l *LocalDB) Get(key []byte) ([]byte, error)

Get 获取key

func (*LocalDB) GetSetKeys

func (l *LocalDB) GetSetKeys() (keys []string)

GetSetKeys get state db set keys

func (*LocalDB) List

func (l *LocalDB) List(prefix, key []byte, count, direction int32) ([][]byte, error)

List 从数据库中查询数据列表

func (*LocalDB) PrefixCount

func (l *LocalDB) PrefixCount(prefix []byte) (count int64)

PrefixCount 从数据库中查询指定前缀的key的数量

func (*LocalDB) ResetCache

func (l *LocalDB) ResetCache()

ResetCache evm 使用

func (*LocalDB) Rollback

func (l *LocalDB) Rollback()

Rollback 回滚修改

func (*LocalDB) Set

func (l *LocalDB) Set(key []byte, value []byte) error

Set 获取key

func (*LocalDB) StartTx

func (l *LocalDB) StartTx()

StartTx reset state db keys

type StateDB

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

StateDB state db for store mavl

func (*StateDB) BatchGet

func (s *StateDB) BatchGet(keys [][]byte) (values [][]byte, err error)

BatchGet batch get keys from state db

func (*StateDB) Begin

func (s *StateDB) Begin()

Begin 开启内存事务处理

func (*StateDB) Commit

func (s *StateDB) Commit() error

Commit canche tx

func (*StateDB) Get

func (s *StateDB) Get(key []byte) ([]byte, error)

Get get value from state db

func (*StateDB) GetSetKeys

func (s *StateDB) GetSetKeys() (keys []string)

GetSetKeys get state db set keys

func (*StateDB) ResetCache

func (s *StateDB) ResetCache()

ResetCache evm 使用

func (*StateDB) Rollback

func (s *StateDB) Rollback()

Rollback reset tx

func (*StateDB) Set

func (s *StateDB) Set(key []byte, value []byte) error

Set set key value to state db

func (*StateDB) StartTx

func (s *StateDB) StartTx()

StartTx reset state db keys

type StateDBOption

type StateDBOption struct {
	EnableMVCC bool
	Height     int64
}

StateDBOption state db option enable mvcc