Struct SessionRunRegistration 

pub struct SessionRunRegistration { /* private fields */ }

Exact-run ownership lease returned by SessionActivationRouter::register_run.

The lease deliberately owns the safe-point receiver. Dropping it before the normal finalization handshake schedules exact-run cleanup, reconciles the durable activation watermark, and gives the router one chance to launch a successor. A stale lease can never clear a newer owner.

Implementations

impl SessionRunRegistration

pub fn notifications_mut(&mut self) -> &mut Receiver<u64>

pub fn set_abort_cleanup<F, Fut>(&mut self, cleanup: F)

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

Run host-specific exact-reservation cleanup before an abandoned owner asks the router to reserve a successor.

pub async fn begin_finalization(&mut self)

pub async fn quarantine(self)

Keep this exact logical owner finalizing when its physical stop or terminal delivery is unconfirmed. Dropping this lease must not run the usual abandoned-owner recovery and launch a successor.

Recovery must explicitly reconcile the retained owner before finishing finalization. Disarm before the await so cancelling quarantine itself cannot accidentally release the owner.

pub async fn abandon(self)

Synchronously abandon this exact ownership lease.

Most cancellation paths can rely on Drop, which schedules the same cleanup. Startup paths that must return a truthful retryable response use this method so the runner slot and router owner are released before the response becomes observable. Cleanup runs in a detached owned task: cancelling the caller’s wait cannot strand an already-taken host cleanup closure or this router owner.

pub async fn finish( self, admitted_generation: u64, ) -> Result<Option<SessionActivationDisposition>, SessionActivationError>

Complete the normal exact-owner handshake. The Drop fallback remains armed across the await and is disabled only after finalization returns.

Trait Implementations

impl Drop for SessionRunRegistration

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.