Struct SupervisorApiAdapter 

pub struct SupervisorApiAdapter { /* private fields */ }

ApiHandler implementation backed by SupervisorApi.

Desired writes, reads, watches, history, deletion, and output delegate to the supervisor. Core errors are converted into ApiError categories.

Visibility

Embedded tasks remain available through the in-process core API. They are absent through this adapter.

See Also

• ApiHandler defines the transport contract.
• ApiError defines the mapped error categories.

Implementations

impl SupervisorApiAdapter

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

Creates an adapter for a running supervisor.

Trait Implementations

impl ApiHandler for SupervisorApiAdapter

fn create_task<'life0, 'async_trait>( &'life0 self, manifest: TaskManifest, ) -> Pin<Box<dyn Future<Output = Result<Task, ApiError>> + Send + 'async_trait>>

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

Creates one named task resource.

fn apply_task<'life0, 'async_trait>( &'life0 self, manifest: TaskManifest, preconditions: WritePreconditions, ) -> Pin<Box<dyn Future<Output = Result<Task, ApiError>> + Send + 'async_trait>>

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

Creates or updates the task addressed by metadata.name.

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

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

Returns the current task resource with this name.

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,

Returns one filtered task page.

fn watch_tasks<'life0, 'async_trait>( &'life0 self, filter: TaskFilter, resource_version: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<TaskWatchEventStream, ApiError>> + Send + 'async_trait>>

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

Watches changes to tasks that match the filter.

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,

Lists one task’s execution attempts from oldest to newest.

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

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

Stops and removes one task and 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,

Subscribes to one task’s live output.