AdminService

ora_proto::server::v1::admin_service_server

Trait AdminService 

Source 
pub trait AdminService:
    Send
    + Sync
    + 'static {

Show 15 methods    // 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 add_job_if_not_exists<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddJobIfNotExistsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AddJobIfNotExistsResponse>, 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 add_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AddSchedulesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn add_schedule_if_not_exists<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddScheduleIfNotExistsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AddScheduleIfNotExistsResponse>, 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 add_job_if_not_exists<'life0, 'async_trait>( &'life0 self, request: Request<AddJobIfNotExistsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddJobIfNotExistsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Add a job or return the first job that matches the given filter.

This is semantically equivalent to sending a CountJobs request and adding the job if the count is 0. The difference is that this method is atomic thus it is not possible for another client to add the same job between the CountJobs and AddJobs calls.

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.

Deprecated: use AddSchedules instead.

Source

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

Add schedules.

Source

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

Add a schedule or return the first schedule that matches the given filter.

This is semantically equivalent to sending a CountSchedules request and adding the schedule if the count is 0. The difference is that this method is atomic thus it is not possible for another client to add the same schedule between the CountSchedules and CreateSchedules calls.

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§