Struct SupervisorApiAdapter 

pub struct SupervisorApiAdapter { /* private fields */ }

Adapter that bridges SupervisorApi to ApiHandler.

Ready-to-use implementation that directly delegates to SupervisorApi.

Also

• ApiHandler the trait this adapter implements.
• ApiError::Core wraps CoreError from the supervisor.

Implementations

impl SupervisorApiAdapter

pub fn new(supervisor: Arc<SupervisorApi>) -> Self

Create a new adapter wrapping the given supervisor.

Trait Implementations

impl ApiHandler for SupervisorApiAdapter

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.

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.

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.