subliminal_protos_rust::db::db_handler_server

Trait DbHandler

Source 
pub trait DbHandler:
    Send
    + Sync
    + 'static {
    // Required methods
    fn fetch_task_request_record<'life0, 'async_trait>(
        &'life0 self,
        request: Request<FetchTaskRequestRecordRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TaskRequestRecord>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn fetch_task_execution_record<'life0, 'async_trait>(
        &'life0 self,
        request: Request<FetchTaskExecutionRecordRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn initialize_task_request<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InitializeTaskRequestRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TaskRequestRecord>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn initialize_task_execution<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InitializeTaskExecutionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_task_execution<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateTaskExecutionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

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

Required Methods§

Source

fn fetch_task_request_record<'life0, 'async_trait>( &'life0 self, request: Request<FetchTaskRequestRecordRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TaskRequestRecord>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn fetch_task_execution_record<'life0, 'async_trait>( &'life0 self, request: Request<FetchTaskExecutionRecordRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn initialize_task_request<'life0, 'async_trait>( &'life0 self, request: Request<InitializeTaskRequestRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TaskRequestRecord>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn initialize_task_execution<'life0, 'async_trait>( &'life0 self, request: Request<InitializeTaskExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn update_task_execution<'life0, 'async_trait>( &'life0 self, request: Request<UpdateTaskExecutionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TaskExecutionRecord>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§