Struct BusEvent 

pub struct BusEvent(pub Value);

A parsed NOTIFY payload. Kept as loose JSON plus typed accessors so adding fields to the triggers never breaks older consumers.

Tuple Fields

0: Value

Implementations

impl BusEvent

pub fn kind(&self) -> &str

pub fn team_id(&self) -> Option<Uuid>

pub fn recipient_agent_id(&self) -> Option<Uuid>

pub fn sender_agent_id(&self) -> Option<Uuid>

pub fn channel_id(&self) -> Option<Uuid>

pub fn message_id(&self) -> Option<i64>

pub fn recipient_session(&self) -> Option<&str>

Working context this message was addressed to, if it was addressed to one. Absent means every session of the recipient.

pub fn sender_session(&self) -> Option<&str>

Working context the message was sent from, if any.

pub fn is_announcement(&self) -> bool

Was this posted as an announcement — something the sender judged worth interrupting the whole team for?

pub fn is_direct_message(&self) -> bool

pub fn visible_to(&self, team_id: Uuid, agent_id: Uuid, session: &str) -> bool

Is this event visible to session of agent of team?

Direct messages are only visible to their recipient (and sender); everything else is team-wide. A message addressed to one session does not wake the recipient’s other sessions — otherwise every window of a person would wake for a question meant for one of them. It still reaches every session of the sender, which is how a reply finds the window that is blocked waiting for it.

Trait Implementations

impl Clone for BusEvent

fn clone(&self) -> BusEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BusEvent

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

Formats the value using the given formatter.