Trait dragonfly_api::manager::manager_server::Manager

pub trait Manager: Send + Sync + 'static {
    // Required methods
    fn get_seed_peer<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetSeedPeerRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<SeedPeer>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_seed_peer<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateSeedPeerRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<SeedPeer>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_scheduler<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetSchedulerRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Scheduler>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_scheduler<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateSchedulerRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Scheduler>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_schedulers<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListSchedulersRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListSchedulersResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_object_storage<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetObjectStorageRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ObjectStorage>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_buckets<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListBucketsRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListBucketsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_applications<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListApplicationsRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListApplicationsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_model<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CreateModelRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn keep_alive<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<KeepAliveRequest>>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

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

Required Methods

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

Get SeedPeer and SeedPeer cluster configuration.

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

Update SeedPeer configuration.

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

Get Scheduler and Scheduler cluster configuration.

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

Update scheduler configuration.

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

List acitve schedulers configuration.

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

Get ObjectStorage configuration.

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

List buckets configuration.

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

List applications configuration.

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

Create model and update data of model to object storage.

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

KeepAlive with manager.

Implementors