Struct PersistentService 

pub struct PersistentService { /* private fields */ }

Transport-independent persistent service. This does not listen on a socket or select v2 for stdio. A local adapter owns framing, write deadlines, and explicit disconnects. Dropping this owner shuts down the daemon; disconnecting a connection does not. A failed/timeout submission is uncertain: never automatically replay a mutation.

Implementations

impl PersistentService

pub fn start() -> Result<Self>

Load the normal runtime once and start its coordinator. No provider work runs until an initialized connection explicitly claims a durable session and starts a turn.

pub fn connect(&self) -> Result<String>

Allocate a pending connection. Initialize it within five seconds.

pub fn submit(&self, connection: &str, record: &[u8]) -> Result<()>

Submit one complete, bounded JSON record. Responses are read with next_record.

pub fn disconnect(&self, connection: &str) -> Result<()>

Revoke this connection’s control and cancel only its login, not accepted turns/settings.

pub fn next_record(&self, connection: &str) -> Result<Option<String>>

Remove one encoded record from the outbound queue. A response’s request ID remains reserved until response_written or disconnect, even after dequeue.

pub fn response_written(&self, connection: &str, request: &str) -> Result<()>

Release response correlation only after the adapter’s write attempt. On write failure, disconnect instead. This acknowledgement never controls execution or lease cleanup.

Trait Implementations

impl Drop for PersistentService

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.