Struct AgdxSend 

pub struct AgdxSend<'a> { /* private fields */ }

One pending AGDX send: the envelope built by its verb, refined by the with_* setters, validated and published by send.

Implementations

impl<'a> AgdxSend<'a>

pub fn with_ancestry( self, parent: Option<ConversationId>, root: Option<ConversationId>, ) -> Self

Mark the envelope as part of a child session whose parent is parent and whose tree is rooted at root.

pub fn with_target(self, target: impl Into<AgentId>) -> Self

Narrow delivery to one agent within the shared topic (routing, never an ACL).

pub fn with_cause(self, cause: RecordId, cause_at: Option<LogPosition>) -> Self

Stamp the causal parent (identity, plus the locator when known).

pub fn with_correlation(self, correlation: CorrelationId) -> Self

Pair with a correlation id (required by status task updates).

pub fn with_idempotency_key(self, key: IdempotencyKey) -> Self

Attach a business idempotency key.

pub fn with_deadline_micros(self, deadline_micros: u64) -> Self

Declare the drop-dead time, epoch micros.

pub fn with_task_state(self, state: TaskState) -> Self

Attach a task state (status task updates require it).

pub fn with_operation(self, operation: impl Into<String>) -> Self

Set the OTel operation name (open vocabulary kinds only).

pub fn with_finish_reason(self, reason: impl Into<String>) -> Self

Set why the model stopped generating.

pub fn with_tool(self, tool: impl Into<String>) -> Self

Set the OTel tool name.

pub fn with_usage(self, usage: TokenUsage) -> Self

Attach token accounting (advisory).

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<Value>, ) -> Self

Add one AGDX-native metadata entry.

pub fn last(self) -> Self

Mark a status terminal (last = true on the final task update).

pub fn content_type(self, content_type: ContentType) -> Self

Declare the body’s codec (agdx.ct). Defaults to raw. An error envelope always carries a CBOR AgentErrorBody, so any other content type on Agdx::fail fails at send.

pub fn body(self, body: impl Into<Vec<u8>>) -> Self

Attach the body for the kinds whose verb does not take one (status, notably the card body of a registry advertisement). The body-carrying verbs (command/respond/emit/fail) set it directly, so this is for refining a status.

pub fn signed_by(self, key: &'a SigningKey) -> Self

Sign the envelope with key just before sending (after every with_* refinement, so the signature covers the final shape). The consuming SDK verifies it against the enrolled key registry, the authorship and authorization gate. Requires the sign feature.

pub fn claim_check( self, store: &'a dyn BlobStore, threshold_bytes: usize, ) -> Self

Claim-check the body against store when it is at or over threshold_bytes at send time: the body is externalized and replaced by the BodyRef capsule, content-type ref. Applied before signing, so a signature covers the capsule the log actually carries. Readers resolve with AgentMessage::resolve_body.

pub async fn send(self) -> Result<Option<RecordId>, LaserError>

Validate, encode, stamp the headers, and publish. Returns the minted record id (chunks have none). When signed_by set a key, the envelope is signed here, last, so the signature covers every refinement.

pub async fn send_receipt(self) -> Result<AgdxReceipt, LaserError>

Like send, and also return where the record was committed.