executor

Documentation

Index

• type BlockExecutor
  • func New(chainLedger ledger.Ledger, logger logrus.FieldLogger) (*BlockExecutor, error)
  • func (exec *BlockExecutor) ApplyReadonlyTransactions(txs []*pb.Transaction) []*pb.Receipt
  • func (exec *BlockExecutor) ExecuteBlock(block *pb.Block)
  • func (exec *BlockExecutor) Start() error
  • func (exec *BlockExecutor) Stop() error
  • func (exec *BlockExecutor) SubscribeBlockEvent(ch chan<- events.NewBlockEvent) event.Subscription
  • func (exec *BlockExecutor) SyncExecuteBlock(block *pb.Block)
• type Executor

Types

type BlockExecutor

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

BlockExecutor executes block from order

func New

func New(chainLedger ledger.Ledger, logger logrus.FieldLogger) (*BlockExecutor, error)

New creates executor instance

func (*BlockExecutor) ApplyReadonlyTransactions

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

func (*BlockExecutor) ExecuteBlock

func (exec *BlockExecutor) ExecuteBlock(block *pb.Block)

ExecuteBlock executes block from order

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.NewBlockEvent) event.Subscription

SubscribeBlockEvent registers a subscription of NewBlockEvent.

func (*BlockExecutor) SyncExecuteBlock

func (exec *BlockExecutor) SyncExecuteBlock(block *pb.Block)

type Executor

type Executor interface {
	// Start
	Start() error

	// Stop
	Stop() error

	// ExecutorBlock
	ExecuteBlock(*pb.Block)

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

	// SubscribeBlockEvent
	SubscribeBlockEvent(chan<- events.NewBlockEvent) event.Subscription
}