Struct Machine 

pub struct Machine {
    session_known: bool,
    email: Option<String>,
    link: Link,
    pull_errors: BTreeMap<String, String>,
    status: MuxBusDeliveryStatus,
    paused_since_ms: Option<i64>,
    pause_noted: bool,
    sign_in_notified: bool,
}

Cloud delivery’s state over time, and the episodes that drive the notification and the agents’ notes.

Fields

session_known: bool

email: Option<String>

link: Link

pull_errors: BTreeMap<String, String>

Agents whose REST pull is failing (agent → reason) though the WebSocket may be open: their messages can’t be fetched, so that is not connected either. An agent’s entry clears when its own pull answers, not another agent’s.

status: MuxBusDeliveryStatus

paused_since_ms: Option<i64>

When the current pause began; open until delivery is connected again. A sign-out ends one only if the agents weren’t told about it.

pause_noted: bool

The agents were told about the current pause.

sign_in_notified: bool

The current needs-sign-in episode has had its notification.

Implementations

impl Machine

pub fn new(now_ms: i64) -> Self

pub fn status(&self) -> &MuxBusDeliveryStatus

pub fn saw_session( &mut self, email: Option<String>, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

The subscriber found a sign-in to use (email when it could read one).

pub fn fresh_sign_in( &mut self, email: Option<String>, now_ms: i64, ) -> Vec<Effect>

The user just signed in (muxbus.login saved it): connecting, whatever the broker still says about the sign-in this one replaces.

pub fn signed_out(&mut self, now_ms: i64) -> Vec<Effect>

The user signed out on purpose: not a lost sign-in.

pub fn set_link( &mut self, link: Link, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

pub fn relay_answered( &mut self, agent: &str, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

The relay answered agent’s pull: delivery is healthy as of now_ms.

pub fn pull_failed( &mut self, agent: &str, reason: String, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

agent’s pull (fetch or claim) got no usable answer from the relay.

pub fn keep_pull_errors_of(&mut self, agents: &[String])

Forget pull failures of agents no longer subscribed: they won’t pull again to clear them.

pub fn tick( &mut self, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

Re-derive (the broker may have moved on its own) and release the pause note once it is due.

fn update( &mut self, broker: Option<&CredentialState>, now_ms: i64, ) -> Vec<Effect>

Trait Implementations

impl Clone for Machine

fn clone(&self) -> Machine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Machine

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

Formats the value using the given formatter.