Struct ProcessProducer 

pub struct ProcessProducer { /* private fields */ }

Process producer which manages the construction of a servant instance

Implementations

impl ProcessProducer

pub fn new(send_to_master: &SendToMaster) -> Self

Constructor of a process producer

• send_to_master: &SendToMaster : a channel sender from the servant to the master of the cluster
• Output: the process producer

pub fn named_process(self) -> ProcessInstance

Generate an empty process instance

• Output: a process instance with a future which is always pending (see the definition of terminated())

pub fn named_process_with_data<D>(self, data: D) -> ProcessInstance

where D: 'static + Send,

Generate an empty process instance with data

• data: D : a data
• D : type of the data
• Output: a process instance with data and a future which is always pending (see the definition of terminated())

pub fn named_process_with_future<F>(self, future: F) -> ProcessInstance

where F: Future<Output = ()> + Send + 'static,

Generate a process instance for a given future

• future: F : a future to be run by the process instance
• F : type of the future
• Output: a process instance wrapping the given future

pub fn named_process_with_data_future<D, F>( self, data: D, future: F, ) -> ProcessInstance

where D: 'static + Send, F: Future<Output = ()> + Send + 'static,

Generate a process instance for a given future

• data: D : a data
• future: F : a future to be run by the process instance
• D : type of the data
• F : type of the future
• Output: a process instance wrapping the given future with data

pub fn add_reply2<U, V, F>( &mut self, name_channel: &String, f: F, ) -> Result<(), String>

where F: Fn(&'static mut ArchData<U>) -> Pin<Box<dyn Future<Output = ArchData<V>> + Send>> + Clone + Send + Sync + 'static, U: 'static + SlxData + Send, V: 'static + SlxData,

Add a reply-to-query component of type 2 to the process producer

• name_channel: &String : name of the query channel
  • channels connected to the servant necessarily have different names
• f: F : closure processing the reply
• U : type of the query; needs to implement SlxData
• V : type of the reply; needs to implement SlxData
• F : type of the processing closure; needs to implement Fn(&'static mut ArchData<U>) -> Pin<Box<dyn Future<Output = ArchData<V> > + Send>>
• Output: nothing or an error

pub fn add_reply1<U, F>( &mut self, name_channel: &String, f: F, ) -> Result<(), String>

where F: Fn(Pin<&'static mut ArchData<U>>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync + 'static, U: 'static + SlxData,

Add a reply-to-query component of type 1 to the process producer

• name_channel: &String : name of the query channel
  • channels connected to the servant necessarily have different names
• f: F : closure processing the reply
• U : type of the query and of reply; needs to implement SlxData
• F : type of the processing closure; needs to implement Fn(&'static mut ArchData<U>) -> Pin<Box<dyn Future<Output = ArchData<V> > + Send>>
• Output: nothing or an error

pub fn add_query<U, V>( &mut self, name_channel: &String, capacity: Option<usize>, ) -> Result<(ArchDispatchSender<U>, ArchDispatchReceiver<V>), String>

where U: SlxData, V: SlxData,

Add a query-and-get-reply component to the process producer

• name_channel: &String : name of the query channel
  • channels connected to the servant necessarily have different names
• capacity: Option<usize> : capacity of the channel (None for unlimited)
• U : type of the query; needs to implement SlxData
• V : type of the reply; needs to implement SlxData
• Output: a dispatch sender for the query and a dispatch receiver for the reply or an error

pub fn add_emit<U>( &mut self, name_channel: &String, capacity: Option<usize>, ) -> Result<ArchDispatchSender<U>, String>

where U: SlxData,

Add an emit component to the process producer

• name_channel: &String : name of the emitting channel
  • channels connected to the servant necessarily have different names
• capacity: Option<usize> : capacity of the channel (None for unlimited)
• U : type of the emitted data; needs to implement SlxData
• Output: a dispatch sender for emitting or an error

pub fn add_read<V>( &mut self, name_channel: &String, capacity: Option<usize>, ) -> Result<ArchDispatchReceiver<V>, String>

where V: SlxData,

Add a read component to the process producer

• name_channel: &String : name of the reading channel
  • channels connected to the servant necessarily have different names
• capacity: Option<usize> : capacity of the channel (None for unlimited)
• V : type of the read data; needs to implement SlxData
• Output: a dispatch receiver for reading or an error

pub fn add_ref_read<V, F>( &mut self, name_channel: &String, reader: F, ) -> Result<(), String>

where F: Fn(&'static ArchData<V>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync + 'static, V: 'static + SlxData,

Add a read-by-reference component to the process producer; the data referenceis then processed by a closure

• name_channel: &String : name of the read-by-reference channel
• reader: F : a reader for processing the data reference
  • channels connected to the servant necessarily have different names
• V : type of the read data; needs to implement SlxData
• F : type of the reading closure; needs to implement Fn(&'static ArchData<V>) -> Pin<Box<dyn Future<Output = ()> + Send>>
• Output: nothing or an error