Struct TaskApiService 

pub struct TaskApiService<H> { /* private fields */ }

Generated TaskService implementation over an ApiHandler.

This is the lower-level service implementation. It converts protobuf values and records optional metrics. Use GrpcApi to also install message limits and authentication.

See Also

• GrpcApi builds the configured public service.
• ApiError defines gRPC error mapping.

Implementations

impl<H> TaskApiService<H>

where H: ApiHandler,

pub fn new(handler: Arc<H>) -> Self

Creates a service with the no-op metrics backend.

pub fn new_with_metrics(handler: Arc<H>, metrics: ApiMetricsHandle) -> Self

Creates a service with an explicit metrics backend.

Trait Implementations

impl<H> TaskService for TaskApiService<H>

where H: ApiHandler,

type WatchTasksStream = Pin<Box<dyn Stream<Item = Result<WatchTasksResponse, Status>> + Send>>

Server-streaming Task collection watch.

type StreamTaskLogsStream = Pin<Box<dyn Stream<Item = Result<StreamTaskLogsResponse, Status>> + Send>>

Server-streaming RPC.

fn create_task<'life0, 'async_trait>( &'life0 self, request: Request<CreateTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateTaskResponse>, Status>> + Send + 'async_trait>>

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

Create a named Task resource.

fn apply_task<'life0, 'async_trait>( &'life0 self, request: Request<ApplyTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ApplyTaskResponse>, Status>> + Send + 'async_trait>>

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

Declaratively create or update one named Task resource.

fn get_task<'life0, 'async_trait>( &'life0 self, request: Request<GetTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetTaskResponse>, Status>> + Send + 'async_trait>>

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

Get one Task resource.

fn list_tasks<'life0, 'async_trait>( &'life0 self, request: Request<ListTasksRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListTasksResponse>, Status>> + Send + 'async_trait>>

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

List tasks with optional filters and pagination.

fn watch_tasks<'life0, 'async_trait>( &'life0 self, request: Request<WatchTasksRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchTasksStream>, Status>> + Send + 'async_trait>>

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

Watch task collection changes.

fn list_task_runs<'life0, 'async_trait>( &'life0 self, request: Request<ListTaskRunsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListTaskRunsResponse>, Status>> + Send + 'async_trait>>

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

List the attempt history of one task.

fn delete_task<'life0, 'async_trait>( &'life0 self, request: Request<DeleteTaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteTaskResponse>, Status>> + Send + 'async_trait>>

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

Stop a task and purge its history.

fn stream_task_logs<'life0, 'async_trait>( &'life0 self, request: Request<StreamTaskLogsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamTaskLogsStream>, Status>> + Send + 'async_trait>>

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

Live-tail stdout/stderr events for a task.