Struct PoolSettlementService 

pub struct PoolSettlementService<P: Provider + Clone + 'static> { /* private fields */ }

Seller-side PaymentPool settlement service. Generic over the alloy Provider (a wallet-filled provider is required for the redeem / redeemMany write path). Cheap to construct; owns its background tasks.

Implementations

impl<P: Provider + Clone + 'static> PoolSettlementService<P>

pub async fn bootstrap( provider: P, payment_pool_addr: Address, self_address: Address, store: Arc<dyn PoolStateStore>, checkpoint_store: Arc<dyn KeyedCheckpointStore>, handler: Arc<ClientHandler>, redeem_threshold: U256, redeem_max_vouchers_per_tx: usize, redeem_interval: Duration, metrics: Arc<Metrics>, boot: &BootRetry, pool_view: PoolProjection, redeem_tx: Sender<LaneKey>, redeem_rx: Receiver<LaneKey>, ) -> Result<(Self, Route)>

Bootstrap the service: self-check the contract, spawn the redemption task, and return the service alongside the paid-watermark Route the runtime registers on the shared multiplexed poller.

Errors

Returns an error if the usdc() self-check fails deterministically — a bad payment_pool_address is fatal at bring-up — or if boot’s budget runs out on transient RPC failures.

pub fn redeem_hint_sender(&self) -> Sender<LaneKey>

Sender the voucher-accept path uses to hint that a lane’s accrued claim may be ready to plan into a chunk whose aggregate clears the redemption floor. Cloneable; dropping all senders simply ends the redemption task cleanly.

pub async fn shutdown(&self, deadline: Duration)

Graceful shutdown: quiesce the redeemer, then run one final best-effort redeem sweep bounded by deadline so a lane whose chunk has cleared the floor is not left un-redeemed across the stop. A pool is owner-closed only, so there is nothing to close here — only redeem.

The paid-watermark watcher is now the shared multiplexed poller’s route, not a service-owned task: the runtime cancels the poller (which triggers an async, best-effort flush of this route’s PoolOpened scan checkpoint via CursorStart::flush) before calling this, but only cancels the token — it does not await the poller’s exit — so that flush is not guaranteed to complete before the final sweep below runs. This is fine: the scan checkpoint is independent of the lane-state redeem sweep and idempotent to re-scan, so the two can race without a correctness impact.

Trait Implementations

impl<P: Provider + Clone + 'static> Debug for PoolSettlementService<P>

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

Formats the value using the given formatter.

impl<P: Provider + Clone + 'static> Drop for PoolSettlementService<P>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.