Struct hydro_deploy::hydroflow_crate::service::HydroflowCrateService

pub struct HydroflowCrateService { /* private fields */ }

Implementations

impl HydroflowCrateService

pub fn new( id: usize, src: PathBuf, on: Arc<dyn Host>, bin: Option<String>, example: Option<String>, profile: Option<String>, rustflags: Option<String>, target_dir: Option<PathBuf>, no_default_features: bool, tracing: Option<TracingOptions>, features: Option<Vec<String>>, args: Option<Vec<String>>, display_id: Option<String>, external_ports: Vec<u16>, ) -> Self

pub fn update_meta<T: Serialize>(&mut self, meta: T)

pub fn get_port( &self, name: String, self_arc: &Arc<RwLock<HydroflowCrateService>>, ) -> HydroflowPortConfig

pub fn add_connection( &mut self, self_arc: &Arc<RwLock<HydroflowCrateService>>, my_port: String, sink: &dyn HydroflowSink, ) -> Result<()>

pub fn stdout(&self) -> UnboundedReceiver<String>

pub fn stderr(&self) -> UnboundedReceiver<String>

pub fn exit_code(&self) -> Option<i32>

Trait Implementations

impl Service for HydroflowCrateService

fn collect_resources(&self, _resource_batch: &mut ResourceBatch)

Makes requests for physical resources server ports that this service needs to run. This should not recursively call collect_resources on the host, since we guarantee that collect_resources is only called once per host.

fn deploy<'life0, 'life1, 'async_trait>( &'life0 mut self, resource_result: &'life1 Arc<ResourceResult>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Connects to the acquired resources and prepares the service to be launched.

fn ready<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Launches the service, which should start listening for incoming network connections. The service should not start computing at this point.

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts the service by having it connect to other services and start computations.

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stops the service by having it disconnect from other services and stop computations.