Struct Connected 

pub struct Connected {
    pub welcome: Welcome,
    /* private fields */
}

A connection past Hello/Welcome, before Attach.

Fields

welcome: Welcome

Implementations

impl Connected

pub async fn connect(path: &Path, hello: Hello) -> Result<Self, TransportError>

Hello/Welcome only. Refused{Version} → TransportError::Version; any other refusal → Protocol.

pub async fn ping(&mut self) -> Result<Pong, TransportError>

pub async fn sessions(&mut self) -> Result<Vec<SessionMeta>, TransportError>

pub async fn purge(&mut self) -> Result<Pong, TransportError>

Purge → the daemon runs memstat::purge_arenas(); replies Pong.

pub async fn auth_state( &mut self, query: AuthStateQuery, ) -> Result<AuthStateReply, TransportError>

AuthState → the daemon broker’s in-memory account state. A daemon that predates the frame is AuthStateReply::DaemonPredates; any other error is returned as itself.

pub async fn shutdown(&mut self, force: bool) -> Result<(), TransportError>

pub async fn close( &mut self, id: &SessionId, force: bool, attached: bool, ) -> Result<String, TransportError>

Close{id, force, attached}: end one session with host authority. Ok(text) = the session ended (the actor’s /close reply, with how to continue it). A refusal (work in flight, clients attached without attached, daemon reloading) → Refused(text); no such session → UnknownSession; a daemon that predates Close → DaemonTooOld. Waits up to CLOSE_TIMEOUT: the session saves and runs its end hooks before the daemon answers.

pub async fn pin( &mut self, id: &SessionId, on: bool, ) -> Result<bool, TransportError>

Pin{id, on}: pin or unpin one session with host authority. Ok(on) = the session’s pin is now on. A refusal (daemon reloading, session live in another process) → Refused(text); no such session → UnknownSession; a daemon that predates Pin → DaemonTooOld.

pub async fn reload_extension( &mut self, extension: &str, ) -> Result<Result<ExtensionReloadReport, ExtensionReloadFailure>, TransportError>

ReloadExtension{extension}: stop that extension and start it again from what is installed now. Ok(Ok(report)) = reloaded; Ok(Err(failure)) = the daemon tried and says why not; a refusal (daemon reloading) → Refused(text); a daemon that predates the frame → DaemonTooOld.

pub async fn bye(self)

Say goodbye and drop the connection.