ora_proto::server::v1::admin_service_server

Trait AdminService

Source
pub trait AdminService:
    Send
    + Sync
    + 'static {
    // Provided methods
    fn add_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AddJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn count_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CountJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CountJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_job_types<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListJobTypesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListJobTypesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn cancel_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CancelJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CancelJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn delete_inactive_jobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DeleteInactiveJobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteInactiveJobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_executors<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListExecutorsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListExecutorsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn create_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CreateSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CreateSchedulesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListSchedulesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn count_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CountSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CountSchedulesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn cancel_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CancelSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CancelSchedulesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn delete_inactive_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DeleteInactiveSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteInactiveSchedulesResponse>, 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 AdminServiceServer.

Provided Methods§

Source

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

Add jobs to be executed.

Source

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

List jobs.

Source

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

Count the number of jobs.

Source

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

List all job types.

Source

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

Cancel jobs.

Source

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

Delete inactive jobs from storage.

Source

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

Get information about the executors.

Source

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

Create schedules.

Source

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

List schedules.

Source

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

Count the number of schedules.

Source

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

Cancel schedules.

Source

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

Delete inactive schedules from storage.

Implementors§