executor

Documentation

Index

• Constants
• func NewSerialExecutor(f1 agency.ApplyTxFunc, f2 agency.RegisterContractFunc, ...) agency.TxsExecutor
• type BlockExecutor
  • func New(chainLedger *ledger.Ledger, logger logrus.FieldLogger, client *appchain.Client, ...) (*BlockExecutor, error)
  • func (exec *BlockExecutor) ApplyReadonlyTransactions(txs []pb.Transaction) []*pb.Receipt
  • func (exec *BlockExecutor) ExecuteBlock(block *pb.CommitEvent)
  • func (exec *BlockExecutor) GetBoltContracts() map[string]agency.Contract
  • func (exec *BlockExecutor) Start() error
  • func (exec *BlockExecutor) Stop() error
  • func (exec *BlockExecutor) SubscribeAuditEvent(ch chan<- *pb.AuditTxInfo) event.Subscription
  • func (exec *BlockExecutor) SubscribeBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription
  • func (exec *BlockExecutor) SubscribeLogsEvent(ch chan<- []*pb.EvmLog) event.Subscription
  • func (exec *BlockExecutor) SubscribeNodeEvent(ch chan<- events.NodeEvent) event.Subscription
• type BlockWrapper
• type Executor
• type SerialExecutor
  • func (se *SerialExecutor) AddInterchainCounter(to string, index *pb.VerifiedIndex)
  • func (se *SerialExecutor) AddNormalTx(hash *types.Hash)
  • func (se *SerialExecutor) ApplyTransactions(txs []pb.Transaction, invalidTxs map[int]agency.InvalidReason) []*pb.Receipt
  • func (se *SerialExecutor) GetBoltContracts() map[string]agency.Contract
  • func (se *SerialExecutor) GetDescription() string
  • func (se *SerialExecutor) GetInterchainCounter() map[string][]*pb.VerifiedIndex
  • func (se *SerialExecutor) GetNormalTxs() []*types.Hash

Constants

const (
	GasNormalTx = 21000
	GasFailedTx = 21000
	GasBVMTx    = 21000 * 10
)

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, client *appchain.Client, config *repo.Config, gasPrice *big.Int) (*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) GetBoltContracts

func (exec *BlockExecutor) GetBoltContracts() map[string]agency.Contract

func (*BlockExecutor) Start

func (exec *BlockExecutor) Start() error

Start starts executor

func (*BlockExecutor) Stop

func (exec *BlockExecutor) Stop() error

Stop stops executor

func (*BlockExecutor) SubscribeAuditEvent

func (exec *BlockExecutor) SubscribeAuditEvent(ch chan<- *pb.AuditTxInfo) event.Subscription

func (*BlockExecutor) SubscribeBlockEvent

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

SubscribeBlockEvent registers a subscription of ExecutedEvent.

func (*BlockExecutor) SubscribeLogsEvent

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

func (*BlockExecutor) SubscribeNodeEvent

func (exec *BlockExecutor) SubscribeNodeEvent(ch chan<- events.NodeEvent) event.Subscription

type BlockWrapper

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

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

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

	// SubscribeNodeEvent
	SubscribeNodeEvent(chan<- events.NodeEvent) event.Subscription

	// SubscribeAuditEvent
	SubscribeAuditEvent(chan<- *pb.AuditTxInfo) event.Subscription

	GetBoltContracts() map[string]agency.Contract
}

type SerialExecutor

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

func (*SerialExecutor) AddInterchainCounter

func (se *SerialExecutor) AddInterchainCounter(to string, index *pb.VerifiedIndex)

func (*SerialExecutor) AddNormalTx

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

func (*SerialExecutor) ApplyTransactions

func (se *SerialExecutor) ApplyTransactions(txs []pb.Transaction, invalidTxs map[int]agency.InvalidReason) []*pb.Receipt

func (*SerialExecutor) GetBoltContracts

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

func (*SerialExecutor) GetDescription

func (se *SerialExecutor) GetDescription() string

func (*SerialExecutor) GetInterchainCounter

func (se *SerialExecutor) GetInterchainCounter() map[string][]*pb.VerifiedIndex

func (*SerialExecutor) GetNormalTxs

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