Struct CustomService

pub struct CustomService { /* private fields */ }

Represents an unknown, third-party service that is not part of the Hydroflow ecosystem.

Implementations

impl CustomService

pub fn new(id: usize, on: Arc<dyn Host>, external_ports: Vec<u16>) -> Self

pub fn declare_client(&self, self_arc: &Arc<RwLock<Self>>) -> CustomClientPort

Trait Implementations

impl Service for CustomService

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.