Skip to main content

AdminService

Trait AdminService 

Source
pub trait AdminService:
    Send
    + Sync
    + 'static {
    // Provided methods
    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 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 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 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 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 stop_schedules<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StopSchedulesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<StopSchedulesResponse>, 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 delete_historical_data<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DeleteHistoricalDataRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteHistoricalDataResponse>, 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 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 supported job types.

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 jobs.

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 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 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 schedules.

Source

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

Stop schedules.

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,

List executors.

Source

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

Delete historical data.

  • Inactive jobs.
  • Inactive schedules.
  • Job types that are no longer used.

Implementors§