Struct AgentMessage 

pub struct AgentMessage {
    pub proc: Option<Arc<DaggerSessionProc>>,
    pub selection: Selection,
    pub graphql_client: DynGraphQLClient,
}

Fields

proc: Option<Arc<DaggerSessionProc>>

selection: Selection

graphql_client: DynGraphQLClient

Implementations

impl AgentMessage

pub async fn delivery(&self) -> Result<AgentMessageDelivery, DaggerError>

How the message conclusively landed: opened a new turn (STARTED), was absorbed into the running turn at a step boundary (STEERED), or queued behind it (QUEUED). Blocks until provider or native lifecycle evidence is conclusive. Once recorded, the result or cancellation error is immutable.

pub async fn id(&self) -> Result<Id, DaggerError>

A unique identifier for this AgentMessage.

pub async fn ref(&self) -> Result<String, DaggerError>

The message’s short ref within the receiving agent’s runtime, e.g. “#3”. This is the deterministic token the recipient’s attribution header shows and a reply’s replyTo names — quote it when telling the recipient what to answer.

pub async fn response(&self) -> Result<String, DaggerError>

Block until this message is answered, and return the answer: an explicit reply (a send whose replyTo names this message), or the final reply of the turn that consumed it, whichever comes first. Idempotent: cancel and request the response again freely; concurrent waiters share the result. Fails if the agent stops before the message resolves. On a failed agent it projects the failure — but the message stays pending, so after a resume consumes it, requesting the response again returns the real reply. Refused when called from inside an agent turn whose wait would deadlock: turns should not block on other agents — send without awaiting, and the reply arrives as a message.

Trait Implementations

impl Clone for AgentMessage

fn clone(&self) -> AgentMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl IntoID<Id> for AgentMessage

fn into_id( self, ) -> Pin<Box<dyn Future<Output = Result<Id, DaggerError>> + Send>>

impl Loadable for AgentMessage

fn graphql_type() -> &'static str

The GraphQL type name (e.g. "Container").

fn from_query( proc: Option<Arc<DaggerSessionProc>>, selection: Selection, graphql_client: DynGraphQLClient, ) -> Self

Construct this type from a query selection.

impl Node for AgentMessage

fn id(&self) -> impl Future<Output = Result<Id, DaggerError>> + Send