Struct Retained 

pub struct Retained { /* private fields */ }

Holds only server metadata. No agent message or working stream reaches it.

Implementations

impl Retained

pub fn bind_console(&self, console: &Arc<ConsoleHub>) -> Result<(), AgentError>

Uses the existing console’s signal, with no timer or second publisher.

Errors

A console was already installed.

pub fn value(&self, subject: &str) -> Result<Option<Value>, AgentError>

Reads current metadata without consuming the watcher stream.

Errors

The retained lock is poisoned.

pub fn new( bounds: AgentsConfig, supervisor: ChannelSupervisor, device: &str, ) -> Arc<Self>

Shares the server’s channel scheduler; creates no worker or timer.

pub fn publish(&self, values: &[(String, Value)]) -> Result<(), AgentError>

Installs both presence and state atomically before delivering either.

Errors

Metadata is oversized, a lock is poisoned, or a watcher cannot receive. A delivery failure does not erase the retained values.

pub fn subscribe( self: &Arc<Self>, id: u64, subject: &str, schemas: &[SchemaId], install: Option<InboxInstall>, ) -> Result<ConnectionSubscription, AgentError>

Subscribes under the same lock used by writers: the current value is always queued first and every later change follows it. The supplied wire inbox budget is installed before that first enqueue.

Errors

Unknown subject, too many watchers, a refused schema, or failed delivery.

Trait Implementations

impl Debug for Retained

fn fmt(&self, out: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.