Struct SessionActivationRouter 

pub struct SessionActivationRouter { /* private fields */ }

One router per owning runtime/AppState. All keys are logical Session ids.

Implementations

impl SessionActivationRouter

pub fn new() -> Arc<Self>

pub async fn set_spawner(&self, spawner: Arc<dyn SessionActivationSpawner>)

Late-bind the real server/SDK reservation adapter after its dependency graph has been assembled.

pub fn set_inbox(&self, inbox: Arc<dyn SessionInboxPort>)

Bind the durable inbox used by abandoned-run reconciliation.

pub async fn register_run( self: &Arc<Self>, target_session_id: &str, run_id: &str, ) -> Result<SessionRunRegistration, SessionRunRegistrationError>

Register an execution created by any entry point. The returned receiver is a safe-point wake signal; the loop also drains the durable inbox at every round boundary, so missed/coalesced notifications do not lose data.

pub async fn attach_delivery_sink( &self, target_session_id: &str, sink: UnboundedSender<u64>, ) -> Option<String>

Bind an external actor driver to the current logical-session owner.

Returns the active run id used to correlate every forwarded claim and confirmation. A pending generation is pushed immediately, closing the delivery-before-bind race without making this in-memory signal durable.

pub async fn detach_delivery_sink(&self, target_session_id: &str, run_id: &str)

Remove a driver only when it still belongs to the same activation run. A stale driver can therefore never unbind its successor.

pub async fn owns_run(&self, target_session_id: &str, run_id: &str) -> bool

True only while this exact activation run remains the logical owner.

pub async fn begin_finalization(&self, target_session_id: &str, run_id: &str)

Mark the current run as finalizing before its runner slot becomes available. Deliveries racing this interval are retained in latest_generation and handed to one successor by finish_finalization.

pub async fn finish_finalization( &self, target_session_id: &str, run_id: &str, admitted_generation: u64, ) -> Result<Option<SessionActivationDisposition>, SessionActivationError>

Release the terminal owner and, if the durable transcript cursor is behind a concurrently delivered inbox generation, reserve and launch exactly one successor using the injected real runtime adapter.

pub async fn subscribe(&self, target_session_id: &str) -> Receiver<u64>

Trait Implementations

impl Clone for SessionActivationRouter

fn clone(&self) -> SessionActivationRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SessionActivationRouter

fn default() -> SessionActivationRouter

Returns the “default value” for a type.

impl SessionActivationPort for SessionActivationRouter

fn request_activation<'life0, 'life1, 'async_trait>( &'life0 self, target_session_id: &'life1 str, inbox_generation: u64, ) -> Pin<Box<dyn Future<Output = Result<SessionActivationDisposition, SessionActivationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,