Enum EngineQueries

pub enum EngineQueries {
    Config(Sender<RollupConfig>),
    State(Sender<EngineState>),
    OutputAtBlock {
        block: BlockNumberOrTag,
        sender: Sender<(L2BlockInfo, OutputRoot, EngineState)>,
    },
    StateReceiver(Sender<Receiver<EngineState>>),
    QueueLengthReceiver(Sender<Receiver<usize>>),
    TaskQueueLength(Sender<usize>),
}

Query types supported by the engine for external communication.

Each variant includes a oneshot sender for the response, enabling async request-response patterns. The engine processes these queries and sends responses back through the provided channels.

Variants

Config(Sender<RollupConfig>)

Request the current rollup configuration.

State(Sender<EngineState>)

Request the current EngineState snapshot.

OutputAtBlock

Request the L2 output root for a specific block.

Returns a tuple of block info, output root, and engine state at the requested block.

Fields

block: BlockNumberOrTag

The block number or tag to retrieve the output for.

sender: Sender<(L2BlockInfo, OutputRoot, EngineState)>

Response channel for (block_info, output_root, engine_state).

StateReceiver(Sender<Receiver<EngineState>>)

Subscribe to engine state updates via a watch channel receiver.

QueueLengthReceiver(Sender<Receiver<usize>>)

Development API: Subscribe to task queue length updates.

TaskQueueLength(Sender<usize>)

Development API: Get the current number of pending tasks in the queue.

Implementations

impl EngineQueries

pub async fn handle( self, state_recv: &Receiver<EngineState>, queue_length_recv: &Receiver<usize>, client: &Arc<EngineClient>, rollup_config: &Arc<RollupConfig>, ) -> Result<(), EngineQueriesError>

Handles the engine query request.

Trait Implementations

impl Debug for EngineQueries

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.