Compute a point-in-time snapshot of the current throttle state. Params are derived from `backlog_bytes` on demand; no additional state is stored in `

Returns the CLI label for this txpool scope.

Returns a pinned timer that completes when the calculated deadline is reached.

Sets the gas limit for the transaction.

Display label for pretty output.

Drives one registry call through `dispatch`, returning `(is_revert, bytes)`.

Executes the derivation pipeline to the claimed block. # Errors Returns an error if derivation fails.

Credits `who` with `amount` and grows total supply to match (setup only).

Returns the transaction count for an address in pending state.

Grants `role` to `who` and bumps the role member count (setup only).

Insert cached trie data for a block. Evicts the oldest entries when the cache exceeds capacity.

Reserves the next nonce for transaction signing. On the first call (or after [`reset`](Self::reset)), fetches the current transaction count from the

Return the configured per-request timeout.

Creates a new timestamp ordering (FIFO).

Clone the underlying blockchain provider so callers can inspect chain state.

Reads token state through the accounting port.

Creates a new [`MockOriginSelectorProvider`].

Sets the `fork_choice_updated_v3` response.

Sets the calldata input bytes.

Sets the transaction recipient address.

Returns the L1 wallet address controlled by this key.

Build the flashblock.

Creates and signs a test-account transaction.

Records a confirmed transaction with its gas used and latency.

Run the batch driver loop. Each iteration has two phases: 1. **CPU phase**: drain encoding, apply throttle, recover txpool, submit pending frames. 2.

Bind and start the admin server on the given socket address.

Creates a `backon` [`ExponentialBuilder`] from this configuration.

Polls until `address` has a non-zero ETH balance on the L2.

Set a custom chain spec for the test harness. If not provided, the default genesis is built programmatically.

Marks `account` as a member of `policy_id` and records the policy as existing. For V1 ALLOWLIST policy IDs this authorizes `account`; for BLOCKLIST I

Build a block using the provided transactions and push it through the engine.

Read the raw data of the first channel, if it's timed-out or closed. Returns an error if there is nothing new to read.

Signs, sends, and waits for a transaction against `to`.

Sets the recovery mode state.

Runs a future on the current runtime, or creates one when needed.

Build the resulting [`BaseChainSpec`]. # Panics This function panics if the chain ID and genesis is not set ([`Self::chain`] and [`Self::genesis`]),

Build the next L2 block and advance the internal head.

Helper to create a simple test branch node

Wraps this [`PipelineError`] as a [`PipelineErrorKind::Critical`]. Critical errors indicate fundamental issues that cannot be resolved through retrie

Return the latest recovered block as seen by the local blockchain provider.

Returns the next filter in the cycle.

Starts a system test stack with Beryl active at block 3 and waits for block 4. The returned [`SystemTestStack`] must be kept alive for the duration o

Returns the success status of the receipt's transaction.

Helper to create a test `L2BlockInfo` at a specific block number

Sets the L2 chain ID.

Builds the pending blocks.

Returns the per-account [`AccountState`] (sequences + lock fields).

Convert CLI arguments into a [`BatcherConfig`].

Helper to create nibbles from a vector of u8 values

Parse this handle from the backend session id string.

Reorg the canonical chain back to `number`, discarding all later blocks. Returns the discarded blocks in order (lowest number first) so tests can ins

Returns the chain id the [`build_test_validator`] is configured against.

The gossip topics accepted for new blocks

Sets the value (amount) for the transaction.

Sets the unsafe head

Creates a policy and returns its decoded id.

Compute the block hash by hashing the header fields. Uses alloy's `Header::hash_slow` which hashes the RLP-encoded header.

Returns `(cache_key, revocation_id)` for `cert` from a single X.509 parse. Root certificates use `keccak256(full DER)` as the cache key. Every non-ro

Processes a send error, updating internal state accordingly. - [`TxManagerError::NonceTooLow`] increments the nonce-too-low counter. - [`TxManagerErr

Reads token state through the accounting port.

Runs `body` with a fresh in-memory `AccountConfigurationStorage`.

Signs the transaction and returns it as a recovered envelope. Auto-fetches nonce and base fee from the provider when not explicitly set.

Builds a new block with `block_timestamp` calculated as block time right before sending FCU

Clears all cached classifications and reverse slot mappings.

Sets the estimate for the given resource kind.

Sets up a test instance with default flashblocks configuration. This is the simplified replacement for the `rb_test` macro.

Executes a single scan-validate-prove-submit cycle.