Struct SnapshotBuilder 

pub struct SnapshotBuilder<P> { /* private fields */ }

Builds a consistent snapshot of the exchange state that can be then kept up-to-date by the data from crate::stream::raw.

Implementations

impl<P: Provider + Clone> SnapshotBuilder<P>

pub fn new(chain: &Chain, provider: P) -> Self

Creates a new SnapshotBuilder which fetches the full exchange state at the latest safe/voted block.

pub fn at_block(self, block: BlockId) -> Self

Sets the block number or tag to fetch the state at (default: alloy::eips::BlockNumberOrTag::Safe). If tag is provided, it gets converted to a specific block number first to ensure state consistency.

pub fn with_perpetuals(self, perpetuals: Vec<PerpetualId>) -> Self

Sets the list of perpetual contract IDs to fetch the state for.

An empty list (the default, see Chain::perpetuals) means every perpetual listed on the exchange, discovered on-chain.

pub fn with_accounts(self, accounts: Vec<AccountAddressOrID>) -> Self

Sets the list of addresses to fetch the state of exchange accounts for. Assumes accounts already exist, snapshot creation will fail otherwise.

pub fn with_all_positions(self) -> Self

Forces to fetch all available positions, along with corresponding accounts, but without account state snapshot. Mutually exclusive with Self::with_accounts.

pub fn with_orders_per_batch(self, orders_per_batch: usize) -> Self

Sets the number of orders to fetch in a single batch via multicall (default: 3000). Use if default does not fit node/provider gas and response size limits.

pub fn with_positions_per_batch(self, positions_per_batch: usize) -> Self

Sets the number of positions to fetch in a single batch (default: 3000). Use if default does not fit node/provider gas and response size limits.

pub async fn build(self) -> Result<Exchange, DexError>

Build the snapshot