executor

Documentation

Index

• type BlockExecutor
  • func New(rep *repo.Repo, ledger *ledger.Ledger) (*BlockExecutor, error)
  • func (exec *BlockExecutor) ApplyReadonlyTransactions(txs []*types.Transaction) []*types.Receipt
  • func (exec *BlockExecutor) AsyncExecuteBlock(block *common.CommitEvent)
  • func (exec *BlockExecutor) ExecuteBlock(block *common.CommitEvent)
  • func (exec *BlockExecutor) GetChainConfig() *params.ChainConfig
  • func (exec *BlockExecutor) NewEvmWithViewLedger(txCtx ethvm.TxContext, vmConfig ethvm.Config) (*ethvm.EVM, error)
  • func (exec *BlockExecutor) Start() error
  • func (exec *BlockExecutor) Stop() error
  • func (exec *BlockExecutor) SubscribeBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription
  • func (exec *BlockExecutor) SubscribeBlockEventForRemote(ch chan<- events.ExecutedEvent) event.Subscription
  • func (exec *BlockExecutor) SubscribeLogsEvent(ch chan<- []*types.EvmLog) event.Subscription
• type BlockWrapper
• type Executor
• type InvalidReason

Types

type BlockExecutor

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

BlockExecutor executes block from consensus

func New

func New(rep *repo.Repo, ledger *ledger.Ledger) (*BlockExecutor, error)

New creates executor instance

func (*BlockExecutor) ApplyReadonlyTransactions

func (exec *BlockExecutor) ApplyReadonlyTransactions(txs []*types.Transaction) []*types.Receipt

func (*BlockExecutor) AsyncExecuteBlock

func (exec *BlockExecutor) AsyncExecuteBlock(block *common.CommitEvent)

func (*BlockExecutor) ExecuteBlock

func (exec *BlockExecutor) ExecuteBlock(block *common.CommitEvent)

ExecuteBlock executes block from consensus

func (*BlockExecutor) GetChainConfig

func (exec *BlockExecutor) GetChainConfig() *params.ChainConfig

func (*BlockExecutor) NewEvmWithViewLedger

func (exec *BlockExecutor) NewEvmWithViewLedger(txCtx ethvm.TxContext, vmConfig ethvm.Config) (*ethvm.EVM, error)

func (*BlockExecutor) Start

func (exec *BlockExecutor) Start() error

Start starts executor

func (*BlockExecutor) Stop

func (exec *BlockExecutor) Stop() error

Stop stops executor

func (*BlockExecutor) SubscribeBlockEvent

func (exec *BlockExecutor) SubscribeBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription

SubscribeBlockEvent registers a subscription of ExecutedEvent.

func (*BlockExecutor) SubscribeBlockEventForRemote

func (exec *BlockExecutor) SubscribeBlockEventForRemote(ch chan<- events.ExecutedEvent) event.Subscription

SubscribeBlockEventForRemote registers a subscription of ExecutedEvent.

func (*BlockExecutor) SubscribeLogsEvent

func (exec *BlockExecutor) SubscribeLogsEvent(ch chan<- []*types.EvmLog) event.Subscription

type BlockWrapper

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

type Executor

type Executor interface {
	// Start
	Start() error

	// Stop
	Stop() error

	// AsyncExecutorBlock
	AsyncExecuteBlock(commitEvent *common.CommitEvent)

	ExecuteBlock(commitEvent *common.CommitEvent)

	// ApplyReadonlyTransactions execute readonly tx
	ApplyReadonlyTransactions(txs []*types.Transaction) []*types.Receipt

	// SubscribeBlockEvent
	SubscribeBlockEvent(chan<- events.ExecutedEvent) event.Subscription

	// SubscribeBlockEventForRemote
	SubscribeBlockEventForRemote(chan<- events.ExecutedEvent) event.Subscription

	// SubscribeLogEvent
	SubscribeLogsEvent(chan<- []*types.EvmLog) event.Subscription

	NewEvmWithViewLedger(txCtx vm.TxContext, vmConfig vm.Config) (*vm.EVM, error)

	GetChainConfig() *params.ChainConfig
}

type InvalidReason

type InvalidReason string