executing

package
v1.0.0-beta.5 Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchData

type BatchData struct {
	*coresequencer.Batch
	time.Time
	Data [][]byte
}

BatchData represents batch data from sequencer

type Executor

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

Executor handles block production, transaction processing, and state management

func NewExecutor

func NewExecutor(
	store store.Store,
	exec coreexecutor.Executor,
	sequencer coresequencer.Sequencer,
	signer signer.Signer,
	cache cache.Manager,
	metrics *common.Metrics,
	config config.Config,
	genesis genesis.Genesis,
	headerBroadcaster broadcaster[*types.SignedHeader],
	dataBroadcaster broadcaster[*types.Data],
	logger zerolog.Logger,
	options common.BlockOptions,
	errorCh chan<- error,
) (*Executor, error)

NewExecutor creates a new block executor. The executor is responsible for: - Block production from sequencer batches - State transitions and validation - P2P broadcasting of produced blocks - DA submission of headers and data

func (*Executor) GetCoreExecutor

func (e *Executor) GetCoreExecutor() coreexecutor.Executor

GetCoreExecutor returns the underlying core executor for testing purposes

func (*Executor) GetLastState

func (e *Executor) GetLastState() types.State

GetLastState returns the current state

func (*Executor) HasPendingTxNotification

func (e *Executor) HasPendingTxNotification() bool

HasPendingTxNotification checks if there's a pending transaction notification It is used for testing purposes

func (*Executor) NotifyNewTransactions

func (e *Executor) NotifyNewTransactions()

NotifyNewTransactions signals that new transactions are available

func (*Executor) SetLastState

func (e *Executor) SetLastState(state types.State)

SetLastState updates the current state

func (*Executor) Start

func (e *Executor) Start(ctx context.Context) error

Start begins the execution component

func (*Executor) Stop

func (e *Executor) Stop() error

Stop shuts down the execution component

Jump to

Keyboard shortcuts

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