executor

Documentation

Index

• type AsyncBlockExecutor
• type AsyncExecutor
  • func NewAsyncExecutor(executeFn Executor) *AsyncExecutor
  • func (exe *AsyncExecutor) Execute(block *types.Block, parent *types.Block) error
  • func (exe *AsyncExecutor) ExecuteStatus() <-chan *BlockExecuteStatus
  • func (exe *AsyncExecutor) Stop()
• type BlockExecuteStatus
• type BlockExecutor
• type Executor

Types

type AsyncBlockExecutor

type AsyncBlockExecutor interface {
	BlockExecutor
	Stop()
	//Asynchronous acquisition block execution results
	ExecuteStatus() <-chan *BlockExecuteStatus
}

AsyncBlockExecutor defines the interface of the asynchronous executor.

type AsyncExecutor

type AsyncExecutor struct {
	AsyncBlockExecutor
	// contains filtered or unexported fields
}

AsyncExecutor async block executor implement.

func NewAsyncExecutor

func NewAsyncExecutor(executeFn Executor) *AsyncExecutor

NewAsyncExecutor new a async block executor.

func (*AsyncExecutor) Execute

func (exe *AsyncExecutor) Execute(block *types.Block, parent *types.Block) error

Execute async execute block.

func (*AsyncExecutor) ExecuteStatus

func (exe *AsyncExecutor) ExecuteStatus() <-chan *BlockExecuteStatus

ExecuteStatus return a channel for notify block execute result.

func (*AsyncExecutor) Stop

func (exe *AsyncExecutor) Stop()

Stop stop async exector.

type BlockExecuteStatus

type BlockExecuteStatus struct {
	Hash   common.Hash
	Number uint64
	Err    error
}

BlockExecuteStatus is block execution results, including block Hash, block Number, error message

type BlockExecutor

type BlockExecutor interface {
	//Execution block, you need to pass in the parent block to find the parent block state
	Execute(block *types.Block, parent *types.Block) error
}

BlockExecutor defines the interface of the executor.

type Executor

type Executor func(block *types.Block, parent *types.Block) error

Executor defines an execution function.