Struct SubscriptionRequest 

pub struct SubscriptionRequest {
    pub uri: String,
    pub action: SubscriptionAction,
    pub condition: Option<Value>,
}

A resource (un)subscription an agent requested for itself via the subscribe/unsubscribe/await_resource self-tools. The reactive daemon applies it to its live subscriptions + router after the run, so an agent can widen or narrow what wakes it. Honoured only under a daemon. Not Eq, because a condition may carry a JSON number.

Fields

uri: String

action: SubscriptionAction

condition: Option<Value>

Optional content predicate (raw self-tool args, e.g. {"pointer":"/status","op":"eq","value":"ready"}) for a conditional await_resource subscribe — the route fires only when the resource content satisfies it. Validated at tool-call time, then re-parsed into a content-predicate condition when the daemon arms the route. None means fire on any update (plain subscribe). Skipped in the wire form when absent, so an unsubscribe / plain subscribe carries no extra key.

Trait Implementations

impl Clone for SubscriptionRequest

fn clone(&self) -> SubscriptionRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SubscriptionRequest

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SubscriptionRequest

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 SubscriptionRequest