Trait ApiHandler 

pub trait ApiHandler:
    Send
    + Sync
    + 'static {
    // Required methods
    fn submit_task<'life0, 'async_trait>(
        &'life0 self,
        spec: TaskSpec,
    ) -> Pin<Box<dyn Future<Output = Result<TaskId, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_task_status<'life0, 'life1, 'async_trait>(
        &'life0 self,
        id: &'life1 TaskId,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Task>, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn query_tasks<'life0, 'async_trait>(
        &'life0 self,
        query: TaskQuery,
    ) -> Pin<Box<dyn Future<Output = Result<TaskPage<Task>, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_task_runs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        id: &'life1 TaskId,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskRun>, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn delete_task<'life0, 'life1, 'async_trait>(
        &'life0 self,
        id: &'life1 TaskId,
    ) -> Pin<Box<dyn Future<Output = Result<(), ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;

    // Provided methods
    fn apply_task<'life0, 'async_trait>(
        &'life0 self,
        spec: TaskSpec,
    ) -> Pin<Box<dyn Future<Output = Result<TaskId, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn stream_task_logs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        _id: &'life1 TaskId,
    ) -> Pin<Box<dyn Future<Output = Result<OutputEventStream, ApiError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
}

Task execution API handler.

Also

• SupervisorApiAdapter ready-to-use implementation.
• ApiError error type returned by all methods.

This trait abstracts the backend implementation, allowing users to:

• Use the provided SupervisorApiAdapter
• Implement custom handlers with additional logic (auth, rate limiting, etc.)

API surface

Method	HTTP	gRPC
submit_task	POST /api/v1/tasks	SubmitTask
apply_task	PUT /api/v1/tasks	ApplyTask
get_task_status	GET /api/v1/tasks/{id}	GetTaskStatus
query_tasks	GET /api/v1/tasks	ListTasks
list_task_runs	GET /api/v1/tasks/{id}/runs	ListTaskRuns
delete_task	DELETE /api/v1/tasks/{id}	DeleteTask
stream_task_logs	GET /api/v1/tasks/{id}/logs	StreamTaskLogs

Required Methods

fn submit_task<'life0, 'async_trait>( &'life0 self, spec: TaskSpec, ) -> Pin<Box<dyn Future<Output = Result<TaskId, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submit a new task for execution.

fn get_task_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<Task>, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get current status of a task by ID.

fn query_tasks<'life0, 'async_trait>( &'life0 self, query: TaskQuery, ) -> Pin<Box<dyn Future<Output = Result<TaskPage<Task>, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query tasks with combined filters and pagination.

Supports filtering by slot and/or status simultaneously, with offset/limit pagination. Returns a page with total count.

fn list_task_runs<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskRun>, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List execution history for a specific task (oldest first).

fn delete_task<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop a task and purge its run history.

Idempotent: returns Ok(()) whether the task is currently registered on the agent. Errors only on supervisor cancellation failures (timeout, internal error).

Provided Methods

fn apply_task<'life0, 'async_trait>( &'life0 self, spec: TaskSpec, ) -> Pin<Box<dyn Future<Output = Result<TaskId, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Apply a spec to its slot (declarative upsert). Returns the id of the task running in the slot after apply.

Note: this forces AdmissionPolicy::Replace, overriding any admission policy on the supplied spec — that is the point of “apply” (latest spec wins the slot). Use submit_task to honor the spec’s own admission policy.

fn stream_task_logs<'life0, 'life1, 'async_trait>( &'life0 self, _id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<OutputEventStream, ApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe to the live-tail stream of stdout/stderr lines for a task.

Returns an OutputEventStream that yields OutputEvents in real time. The stream covers all subsequent runs of the task (multi-run merge) and ends when the task is fully terminal and evicted.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ApiHandler for SupervisorApiAdapter