Struct AgentPresence 

pub struct AgentPresence {
    pub v: u32,
    pub agent: AgentId,
    pub inbox: Option<String>,
}

The live presence an agent advertises in its connection metadata (AGDX_SET_CLIENT_METADATA), the body the discovery read surfaces per connection.

Distinct from AgentCard on purpose. The card is durable, replayable capability that outlives a brief disconnect (folded from the registry topic). Presence is live transport truth: it vanishes on disconnect and answers “where do I send this agent work right now,” carrying the inbox topic the agent is currently consuming, which may be a topic it created for one workflow and drops when done. Routing resolves a capable agent to its inbox through this, never through a hard-coded shared topic name, which does not scale across users that each own their own streams and topics.

The body rides the opaque connection-metadata bytes with no envelope header, so it carries its own version v (PRESENCE_OP_VERSION). The metadata channel stays opaque: a non-agent client advertises whatever blob its own consumers interpret, and only an AGDX agent advertises this shape.

Fields

v: u32

The presence body version, carried in-band (the metadata bytes have no out-of-band version header).

agent: AgentId

Which agent this connection is, the link from a connection (keyed by client_id/user_id) to its AgentCard (keyed by agent id). A claim like every agent-written field, cross-checked against the verified user_id the connection authenticated as.

inbox: Option<String>

The topic this agent currently consumes its work on, within the stream its connection is scoped to. Absent means liveness-only presence with no declared inbox, so routing falls through to another signal.

Implementations

impl AgentPresence

pub fn new(agent: AgentId) -> Self

Presence for agent at the current PRESENCE_OP_VERSION, with no declared inbox yet.

pub fn with_inbox(self, inbox: impl Into<String>) -> Self

Declare the inbox topic this agent consumes its work on.

pub fn validate(&self) -> Result<(), ValidateError>

Check a decoded presence body against the caps: the inbox topic is bounded like every vocabulary string.

Trait Implementations

impl Clone for AgentPresence

fn clone(&self) -> AgentPresence

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentPresence

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentPresence

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for AgentPresence

impl PartialEq for AgentPresence

fn eq(&self, other: &AgentPresence) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for AgentPresence

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AgentPresence