executing

Mar 12, 2026

Changes in this version

+ type BatchData struct

+ Data [][]byte

+ type BlockProducer interface

+ ApplyBlock func(ctx context.Context, header types.Header, data *types.Data) (types.State, error)

+ CreateBlock func(ctx context.Context, height uint64, batchData *BatchData) (*types.SignedHeader, *types.Data, error)

+ ProduceBlock func(ctx context.Context) error

+ RetrieveBatch func(ctx context.Context) (*BatchData, error)

+ func WithTracingBlockProducer(inner BlockProducer) BlockProducer

+ type Executor struct

+ func NewExecutor(store store.Store, exec coreexecutor.Executor, ...) (*Executor, error)

+ func (e *Executor) ApplyBlock(ctx context.Context, header types.Header, data *types.Data) (types.State, error)

+ func (e *Executor) CreateBlock(ctx context.Context, height uint64, batchData *BatchData) (*types.SignedHeader, *types.Data, error)

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

+ func (e *Executor) HasPendingTxNotification() bool

+ func (e *Executor) IsSyncedWithRaft(raftState *raft.RaftBlockState) (int, error)

+ func (e *Executor) NotifyNewTransactions()

+ func (e *Executor) ProduceBlock(ctx context.Context) error

+ func (e *Executor) RetrieveBatch(ctx context.Context) (*BatchData, error)

+ func (e *Executor) SetBlockProducer(bp BlockProducer)

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

+ func (e *Executor) Stop() error