Struct SessionProvider 

pub struct SessionProvider { /* private fields */ }

Implementations

impl SessionProvider

pub fn new( adapter: Adapter, base_key: impl Into<String>, sender: UnboundedSender<Message>, ) -> Self

pub fn job(&self) -> Option<u64>

pub fn active_key(&self) -> &str

pub fn inference_active(&self) -> bool

pub fn mailbox_flush_active(&self) -> bool

pub async fn drive( &mut self, durable: &mut DurableThread, usage: &mut ModelUsageSession, view: &mut SessionView, ) -> Result<(), String>

pub fn launch_mailbox_flush( &mut self, durable: &DurableThread, view: &mut SessionView, prepared: PreparedMailboxFlush, ) -> Result<(), String>

pub fn accept_mailbox_flush( &mut self, durable: &mut DurableThread, job: u64, prepared: PreparedMailboxFlush, result: Result<(), String>, ) -> Result<(), String>

pub fn accept_inferred(&mut self, job: u64) -> Result<(), String>

pub fn settle_success(&mut self, shim: ActorShim)

pub fn settle_failure(&mut self)

pub fn prepare_restart(&self) -> Result<RestartPlan, ActorError>

pub fn install_restart(&mut self, plan: RestartPlan)

pub fn abort(&mut self)