Struct shuttle_runtime::Alpha

pub struct Alpha<L, S> { /* private fields */ }

Implementations

impl<L, S> Alpha<L, S>

pub fn new(provisioner_address: Endpoint, loader: L, env: Environment) -> Self

Trait Implementations

impl<L, S> Runtime for Alpha<L, S>where L: Loader<ProvisionerFactory, Service = S> + Send + 'static, S: Service + Send + 'static,

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

Load a service file to be ready to start it

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

Start a loaded service file

fn stop<'life0, 'async_trait>( &'life0 self, _request: Request<StopRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<StopResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Stop a started service

type SubscribeStopStream = ReceiverStream<Result<SubscribeStopResponse, Status>>

Server streaming response type for the SubscribeStop method.

fn subscribe_stop<'life0, 'async_trait>( &'life0 self, _request: Request<SubscribeStopRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStopStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Channel to notify a service has been stopped