execution

package
v1.0.0-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 26, 2026 License: Apache-2.0 Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DummyExecutor

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

DummyExecutor is a dummy implementation of the Executor interface for testing

func NewDummyExecutor

func NewDummyExecutor() *DummyExecutor

NewDummyExecutor creates a new dummy DummyExecutor instance

func (*DummyExecutor) ExecuteTxs

func (e *DummyExecutor) ExecuteTxs(ctx context.Context, txs [][]byte, blockHeight uint64, timestamp time.Time, prevStateRoot []byte) ([]byte, error)

ExecuteTxs simulate execution of transactions.

func (*DummyExecutor) FilterTxs

func (e *DummyExecutor) FilterTxs(ctx context.Context, txs [][]byte, maxBytes, maxGas uint64, hasForceIncludedTransaction bool) ([]FilterStatus, error)

FilterTxs validates force-included transactions and applies size filtering. For DummyExecutor, no tx validation is done but size filtering is applied.

func (*DummyExecutor) GetExecutionInfo

func (e *DummyExecutor) GetExecutionInfo(ctx context.Context) (ExecutionInfo, error)

GetExecutionInfo returns execution layer parameters. For DummyExecutor, returns MaxGas=0 indicating no gas-based filtering.

func (*DummyExecutor) GetStateRoot

func (e *DummyExecutor) GetStateRoot() []byte

GetStateRoot returns the current state root in a thread-safe manner

func (*DummyExecutor) GetTxs

func (e *DummyExecutor) GetTxs(context.Context) ([][]byte, error)

GetTxs returns the list of transactions within the DummyExecutor instance and an error if any.

func (*DummyExecutor) InitChain

func (e *DummyExecutor) InitChain(ctx context.Context, genesisTime time.Time, initialHeight uint64, chainID string) ([]byte, error)

InitChain initializes the chain state with the given genesis time, initial height, and chain ID. It returns the state root hash and an error if the initialization fails.

func (*DummyExecutor) InjectTx

func (e *DummyExecutor) InjectTx(tx []byte)

InjectTx adds a transaction to the internal list of injected transactions in the DummyExecutor instance.

func (*DummyExecutor) SetFinal

func (e *DummyExecutor) SetFinal(ctx context.Context, blockHeight uint64) error

SetFinal marks block at given height as finalized.

type ExecutionInfo

type ExecutionInfo struct {
	// MaxGas is the maximum gas allowed for transactions in a block.
	// For non-gas-based execution layers, this should be 0.
	MaxGas uint64
}

ExecutionInfo contains execution layer parameters that may change per block.

type Executor

type Executor interface {
	// InitChain initializes a new blockchain instance with genesis parameters.
	// Requirements:
	// - Must generate initial state root representing empty/genesis state
	// - Must validate and store genesis parameters for future reference
	// - Must ensure idempotency (repeated calls with identical parameters should return same results)
	// - Must return error if genesis parameters are invalid
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	// - genesisTime: timestamp marking chain start time in UTC
	// - initialHeight: First block height (must be > 0)
	// - chainID: Unique identifier string for the blockchain
	//
	// Returns:
	// - stateRoot: Hash representing initial state
	// - err: Any initialization errors
	InitChain(ctx context.Context, genesisTime time.Time, initialHeight uint64, chainID string) (stateRoot []byte, err error)

	// GetTxs fetches available transactions from the execution layer's mempool.
	// Requirements:
	// - Must return currently valid transactions only
	// - Must handle empty mempool case gracefully
	// - Must respect context cancellation/timeout
	// - Should perform basic transaction validation
	// - Should not remove transactions from mempool
	// - May remove invalid transactions from mempool
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	//
	// Returns:
	// - [][]byte: Slice of valid transactions
	// - error: Any errors during transaction retrieval
	GetTxs(ctx context.Context) ([][]byte, error)

	// ExecuteTxs processes transactions to produce a new block state.
	// Requirements:
	// - Must validate state transition against previous state root
	// - Must handle empty transaction list
	// - Must handle gracefully gibberish transactions
	// - Must maintain deterministic execution
	// - Must respect context cancellation/timeout
	// - The rest of the rules are defined by the specific execution layer
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	// - txs: Ordered list of transactions to execute
	// - blockHeight: Height of block being created (must be > 0)
	// - timestamp: Block creation time in UTC
	// - prevStateRoot: Previous block's state root hash
	//
	// Returns:
	// - updatedStateRoot: New state root after executing transactions
	// - err: Any execution errors
	ExecuteTxs(ctx context.Context, txs [][]byte, blockHeight uint64, timestamp time.Time, prevStateRoot []byte) (updatedStateRoot []byte, err error)

	// SetFinal marks a block as finalized at the specified height.
	// Requirements:
	// - Must verify block exists at specified height
	// - Must be idempotent
	// - Must maintain finality guarantees (no reverting finalized blocks)
	// - Must respect context cancellation/timeout
	// - Should clean up any temporary state/resources
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	// - blockHeight: Height of block to finalize
	//
	// Returns:
	// - error: Any errors during finalization
	SetFinal(ctx context.Context, blockHeight uint64) error

	// GetExecutionInfo returns current execution layer parameters.
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	//
	// Returns:
	// - info: Current execution parameters
	// - error: Any errors during retrieval
	GetExecutionInfo(ctx context.Context) (ExecutionInfo, error)

	// FilterTxs validates force-included transactions and applies gas and size filtering for all passed txs.
	//
	// The function marks transaction with a filter status. The sequencer knows how to proceed with it:
	// - Transactions passing all filters constraints and that can be included (FilterOK)
	// - Invalid/unparseable force-included transactions (gibberish) (FilterRemove)
	// - Any transactions that would exceed the cumulative gas limit (FilterPostpone)
	//
	// For non-gas-based execution layers (maxGas=0) should not filter by gas.
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	// - txs: All transactions (force-included + mempool)
	// - maxBytes: Maximum cumulative size allowed (0 means no size limit)
	// - maxGas: Maximum cumulative gas allowed (0 means no gas limit)
	// - hasForceIncludedTransaction: Boolean wether force included txs are present
	//
	// Returns:
	// - result: The filter status of all txs. The len(txs) == len(result).
	// - err: Any errors during filtering (not validation errors, which result in filtering)
	FilterTxs(ctx context.Context, txs [][]byte, maxBytes, maxGas uint64, hasForceIncludedTransaction bool) ([]FilterStatus, error)
}

Executor defines the interface that execution clients must implement to be compatible with Evolve. This interface enables the separation between consensus and execution layers, allowing for modular and pluggable execution environments.

Note: if you are modifying this interface, ensure that all implementations are compatible (evm, abci, protobuf/grpc, etc.)

type FilterStatus

type FilterStatus int

FilterStatus is the result of FilterTxs tx status.

const (
	// FilterOK is the result of a transaction that will make it to the next batch
	FilterOK FilterStatus = iota
	// FilterRemove is the result of a transaction that will be filtered out because invalid (too big, malformed, etc.)
	FilterRemove
	// FilterPostpone is the result of a transaction that is valid but postponed for later processing due to size constraint
	FilterPostpone
)

type HeightProvider

type HeightProvider interface {
	// GetLatestHeight returns the current block height of the execution layer.
	// This is useful for detecting desynchronization between ev-node and the execution layer
	// after crashes or restarts.
	//
	// Parameters:
	// - ctx: Context for timeout/cancellation control
	//
	// Returns:
	// - height: Current block height of the execution layer
	// - error: Any errors during height retrieval
	GetLatestHeight(ctx context.Context) (uint64, error)
}

HeightProvider is an optional interface that execution clients can implement to support height synchronization checks between ev-node and the execution layer.

type Rollbackable

type Rollbackable interface {
	// Rollback resets the execution layer head to the specified height.
	Rollback(ctx context.Context, targetHeight uint64) error
}

Rollbackable is an optional interface that execution clients can implement to support automatic rollback when the execution layer is ahead of the target height. This enables automatic recovery during rolling restarts when the EL has committed blocks that were not replicated to the consensus layer.

Requirements: - Only execution layers supporting in-flight rollback should implement this.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL