Struct TaskDialer 

pub struct TaskDialer { /* private fields */ }

Reusable handle for the control plane’s AgentTaskService.

The durable task-record path a protocol edge drives its lifecycle over. Shares the AgentService endpoint — both are served on one Connect port — so it is built from the same address.

Bearer-only, exactly like ApprovalDialer::with_bearer: these calls send no AgentStart, so no signed attribution envelope rides them.

Implementations

impl TaskDialer

pub fn new(addr: &str) -> Result<Self, DialError>

Build a dialer pointed at addr (expects http://host:port).

Errors

Returns DialError::InvalidAddress if addr isn’t a valid URI, or DialError::Tls if an https endpoint’s TLS setup fails.

pub fn with_bearer(addr: &str, bearer: &str) -> Result<Self, DialError>

Build a dialer pointed at addr, authenticated with bearer.

Errors

Returns DialError::InvalidAddress if addr isn’t a valid URI, DialError::Tls if an https endpoint’s TLS setup fails, or DialError::InvalidBearer if bearer can’t be encoded as an HTTP header value.

pub async fn create_task( &self, task_id: &str, context_id: &str, history: Vec<Vec<u8>>, ) -> Result<AgentTaskRecord, DialError>

Mint a task in AgentTaskState::Submitted and index it under context_id, carrying history as its opening frames.

Errors

Returns DialError::Connect for any transport or encoding error, including the control plane’s refusal of an identity that already exists (already_exists).

pub async fn transition_task( &self, task_id: &str, state: AgentTaskState, successor: AgentTaskTransition, ownership: &AgentTaskOwnership, ) -> Result<AgentTaskRecord, DialError>

Move a live task to state, carrying successor’s frames.

Errors

Returns DialError::Connect for any transport or encoding error, including not_found for an unknown task and failed_precondition for a task that already finished.

pub async fn claim_task( &self, task_id: &str, dispatch_id: &str, worker_instance: &str, attempt_id: &str, appended_history: Vec<Vec<u8>>, ) -> Result<(AgentTaskRecord, AgentTaskOwnership), DialError>

Claims one task for a durable source dispatch before its turn runs.

worker_instance is stable for one edge process and attempt_id for one delivery attempt. Exact retries reuse both; a competing execution must use a different attempt.

Errors

Returns DialError::Connect for transport failures, malformed ownership replies, or a live competing claim.

pub async fn renew_task_claim( &self, task_id: &str, ownership: &AgentTaskOwnership, ordinal: u64, ) -> Result<(), DialError>

Renews one exact task ownership capability without changing its fence.

Errors

Returns DialError::Connect for transport failures or a stale capability. Ambiguous transport outcomes replay the same ordinal.

pub async fn cancel_task( &self, task_id: &str, ) -> Result<AgentTaskRecord, DialError>

Cancel a live task.

Errors

Returns DialError::Connect for any transport or encoding error, including not_found for an unknown task and failed_precondition for a task that already finished — cancellation’s refusal is part of its contract, never a quiet success.

pub async fn get_task( &self, task_id: &str, ) -> Result<Option<AgentTaskRecord>, DialError>

Read one task by identity. None means no task exists under it — a plain absence, not a failure.

Errors

Returns DialError::Connect for any transport or encoding error.

pub async fn list_tasks( &self, context_id: &str, page_size: u32, after: Option<&str>, ) -> Result<AgentTaskPage, DialError>

Read one bounded page of context_id’s tasks, resuming after after when a previous page returned one.

Errors

Returns DialError::Connect for any transport or encoding error, including invalid_argument for a page size above the server maximum.

Trait Implementations

impl Clone for TaskDialer

fn clone(&self) -> TaskDialer

Returns a duplicate of the value.

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

Performs copy-assignment from source.