Module persistence_waiter 

Persistence waiting utilities for benchmarks.

Provides waiting behavior to control benchmark pacing:

• Fixed duration waits: Sleep for a fixed time between blocks
• Persistence-based waits: Wait for blocks to be persisted using reth_subscribePersistedBlock subscription
• Combined mode: Wait at least the fixed duration, and also wait for persistence if the block hasn’t been persisted yet (whichever takes longer)

Structs

PersistenceSubscription 🔒

Wrapper that keeps both the subscription stream and the underlying provider alive. The provider must be kept alive for the subscription to continue receiving events.

PersistenceWaiter 🔒

Encapsulates the block waiting logic.

Constants

DEFAULT_WS_RPC_PORT 🔒

Default WebSocket RPC port for reth.

Functions

derive_ws_rpc_url 🔒

Returns the websocket RPC URL used for the persistence subscription.

engine_url_to_ws_url 🔒

Converts an engine API URL to the default RPC websocket URL.

setup_persistence_subscription 🔒

Establishes a websocket connection and subscribes to reth_subscribePersistedBlock.

wait_for_persistence 🔒

Waits until the persistence subscription reports that target has been persisted.