executor

Documentation

Index

• func NewSerialExecutor(f1 agency.ApplyTxFunc, f2 agency.RegisterContractFunc, ...) agency.TxsExecutor
• type BlockExecutor
  • func New(chainLedger ledger.Ledger, logger logrus.FieldLogger, typ string) (*BlockExecutor, error)
  • func (exec *BlockExecutor) ApplyReadonlyTransactions(txs []*pb.Transaction) []*pb.Receipt
  • func (exec *BlockExecutor) ExecuteBlock(block *pb.CommitEvent)
  • func (exec *BlockExecutor) Start() error
  • func (exec *BlockExecutor) Stop() error
  • func (exec *BlockExecutor) SubscribeBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription
• type Executor
• type SerialExecutor
  • func (se *SerialExecutor) AddInterchainCounter(to string, index uint64)
  • func (se *SerialExecutor) AddNormalTx(hash *types.Hash)
  • func (se *SerialExecutor) ApplyTransactions(txs []*pb.Transaction) []*pb.Receipt
  • func (se *SerialExecutor) GetBoltContracts() map[string]agency.Contract
  • func (se *SerialExecutor) GetInterchainCounter() map[string][]uint64
  • func (se *SerialExecutor) GetNormalTxs() []*types.Hash

Functions

func NewSerialExecutor

func NewSerialExecutor(f1 agency.ApplyTxFunc, f2 agency.RegisterContractFunc, logger logrus.FieldLogger) agency.TxsExecutor

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, typ string) (*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.CommitEvent)

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

SubscribeBlockEvent registers a subscription of ExecutedEvent.

type Executor

type Executor interface {
	// Start
	Start() error

	// Stop
	Stop() error

	// ExecutorBlock
	ExecuteBlock(commitEvent *pb.CommitEvent)

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

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

type SerialExecutor

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

func (*SerialExecutor) AddInterchainCounter

func (se *SerialExecutor) AddInterchainCounter(to string, index uint64)

func (*SerialExecutor) AddNormalTx

func (se *SerialExecutor) AddNormalTx(hash *types.Hash)

func (*SerialExecutor) ApplyTransactions

func (se *SerialExecutor) ApplyTransactions(txs []*pb.Transaction) []*pb.Receipt

func (*SerialExecutor) GetBoltContracts

func (se *SerialExecutor) GetBoltContracts() map[string]agency.Contract

func (*SerialExecutor) GetInterchainCounter

func (se *SerialExecutor) GetInterchainCounter() map[string][]uint64

func (*SerialExecutor) GetNormalTxs

func (se *SerialExecutor) GetNormalTxs() []*types.Hash