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 NewLocalDB(cli queue.Client) 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.Chain33Config) *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) 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) 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 NewLocalDB

func NewLocalDB(cli queue.Client) 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.Chain33Config) *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) 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) 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