Struct ReservationService 

pub struct ReservationService { /* private fields */ }

The verbs. Stateless over a pool; each verb runs in one transaction with the ambient org scope relayed (the module’s uniform posture).

Implementations

impl ReservationService

pub fn new(pool: PgPool) -> Self

pub async fn hold( &self, ref_type: &str, ref_id: Uuid, warehouse_id: Uuid, lines: &[HoldLine], expires_at: DateTime<Utc>, ) -> Result<Vec<HoldAckLine>, ReservationError>

Hold lines for ref at warehouse until expires_at. Idempotent per (ref, item): existing held lines for the ref are replaced. Every line must fit the fresh availability triangle minus held reservations, or the whole hold refuses (all-or-nothing).

pub async fn release( &self, ref_type: &str, ref_id: Uuid, ) -> Result<usize, ReservationError>

Release the ref’s held lines (the cart-close hook). Idempotent.

pub async fn consume( &self, ref_type: &str, ref_id: Uuid, ) -> Result<usize, ReservationError>

Consume the ref’s held lines (the order-confirm bridge: the real move’s reservation takes over). Idempotent.

pub async fn held_for_ref( &self, ref_type: &str, ref_id: Uuid, ) -> Result<Vec<HeldReservation>, ReservationError>

The ref’s held lines (inspect).

pub async fn sweep_expired(&self, limit: i64) -> Result<usize, ReservationError>

The expiry sweep — the abandonment policy. Bounded batches; the caller (a host job pass) loops until it answers zero.

Trait Implementations

impl Clone for ReservationService

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.