pub struct BuyerPendingSettleStoreHandle { /* private fields */ }Expand description
PendingSettleStore over the buyer’s buyer_pending_settle_v1 table,
isolated from the seller’s pending_settle_v1 table so the two settle
sweeps never finalize each other’s closes (#988). Wraps the same shared
PersistentPoolStateStore (one redb file, one handle); hand this to the
buyer service as Arc<dyn PendingSettleStore>.
Implementations§
Source§impl BuyerPendingSettleStoreHandle
impl BuyerPendingSettleStoreHandle
Sourcepub const fn new(inner: Arc<PersistentPoolStateStore>) -> Self
pub const fn new(inner: Arc<PersistentPoolStateStore>) -> Self
Wrap a shared persistent store as the buyer pending-settle store.
Trait Implementations§
Source§impl PendingSettleStore for BuyerPendingSettleStoreHandle
impl PendingSettleStore for BuyerPendingSettleStoreHandle
Source§fn record_pending(&self, entry: &PendingSettle) -> Result<(), StoreError>
fn record_pending(&self, entry: &PendingSettle) -> Result<(), StoreError>
Persist a closed pool awaiting settlement. Overwrites any existing entry
for the same pool (a re-close re-stamps the deadline). Read more
Source§fn load_pending(&self) -> Result<Vec<PendingSettle>, StoreError>
fn load_pending(&self) -> Result<Vec<PendingSettle>, StoreError>
Load every pool awaiting settlement. Called on each sweep tick (and once
at bring-up) to find pools whose grace window has elapsed. Read more
Source§fn forget_pending(&self, pool_id: B256) -> Result<(), StoreError>
fn forget_pending(&self, pool_id: B256) -> Result<(), StoreError>
Drop the pending-settle entry for a finalized pool. Idempotent; a no-op
for an unknown pool. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for BuyerPendingSettleStoreHandle
impl !UnwindSafe for BuyerPendingSettleStoreHandle
impl Freeze for BuyerPendingSettleStoreHandle
impl Send for BuyerPendingSettleStoreHandle
impl Sync for BuyerPendingSettleStoreHandle
impl Unpin for BuyerPendingSettleStoreHandle
impl UnsafeUnpin for BuyerPendingSettleStoreHandle
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestCreates a shared type from an unshared type.