Trait teaclave_proto::teaclave_scheduler_service_proto::teaclave_scheduler_server::TeaclaveScheduler

source · [−]
pub trait TeaclaveScheduler: Send + Sync + 'static {
    fn publish_task<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PublishTaskRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn subscribe<'life0, 'async_trait>(
        &'life0 self,
        request: Request<()>
    ) -> Pin<Box<dyn Future<Output = Result<Response<SubscribeResponse>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn pull_task<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PullTaskRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<PullTaskResponse>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn update_task_status<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateTaskStatusRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn update_task_result<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateTaskResultRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn heartbeat<'life0, 'async_trait>(
        &'life0 self,
        request: Request<HeartbeatRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<HeartbeatResponse>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}
Expand description

Generated trait containing gRPC methods that should be implemented for use with TeaclaveSchedulerServer.

Required Methods

Publisher

Subscriber

Implementors