Struct StarterProducerWithFlow

pub struct StarterProducerWithFlow { /* private fields */ }

Builder for silx network starter, including clusters definitions with: servants names and builder files; data channels names, types and builder files

Implementations

impl StarterProducerWithFlow

pub fn add_query<P, I, O>( self, path: P, name: String, cluster: SocketAddr, in_names: I, out_names: O, max_ping: Duration, size: Option<usize>, ) -> Result<Self, String>

where P: AsRef<Path>, I: IntoIterator<Item = String>, O: IntoIterator<Item = String>,

Add a new intracluster query channel to starters builder

• path: P : path of the file where channel is serialized
• name: String : name of the channel
• cluster: SocketAddr : socket address of the cluster in which the channel operates
• in_names: I : collection of querying servants of the cluster
• out_names: O : collection of replying servants of the cluster
• max_ping: Duration : max ping duration for the channel
• size: Option<usize> : size of the channel (None for unlimited)
• P : type of path
• I : type of the collection of querying servants
• O : type of the collection of replying servants
• Output: completed starter builder or error

pub fn add_broadcast<P, I, O>( self, path: P, name: String, cluster: SocketAddr, in_names: I, out_names: O, max_ping: Duration, size: usize, ) -> Result<Self, String>

where P: AsRef<Path>, I: IntoIterator<Item = String>, O: IntoIterator<Item = String>,

Add a new intracluster broadcast channel to starters builder

• path: P : path of the file where channel is serialized
• name: String : name of the channel
• cluster: SocketAddr : socket address of the cluster in which the channel operates
• in_names: I : collection of querying servants of the cluster
• out_names: O : collection of replying servants of the cluster
• max_ping: Duration : max ping duration for the channel
• size: usize : size of the channel
• P : type of path
• I : type of the collection of querying servants
• O : type of the collection of replying servants
• Output: completed starter builder or error

pub fn add_signal<P, I, O>( self, path: P, name: String, cluster: SocketAddr, in_names: I, out_names: O, max_ping: Duration, ) -> Result<Self, String>

where P: AsRef<Path>, I: IntoIterator<Item = String>, O: IntoIterator<Item = String>,

Add a new signal channel (intracluster) to starters builder

• path: P : path of the file where channel is serialized
• name: String : name of the channel
• cluster: SocketAddr : socket address of the cluster in which the channel operates
• in_names: I : collection of querying servants of the cluster
• out_names: O : collection of replying servants of the cluster
• max_ping: Duration : max ping duration for the channel
• P : type of path
• I : type of the collection of querying servants
• O : type of the collection of replying servants
• Output: completed starter builder or error

pub fn add_net_query<P, I, O>( self, path: P, name: String, in_cluster: SocketAddr, in_names: I, out_cluster: SocketAddr, out_names: O, max_ping: Duration, size: Option<usize>, ) -> Result<Self, String>

where P: AsRef<Path>, I: IntoIterator<Item = String>, O: IntoIterator<Item = String>,

Add a new intercluster query channel to starters builder

• path: P : path of the file where channel is serialized
• name: String : name of the channel
• in_cluster: SocketAddr : socket address of the cluster from which the channel operates
• in_names: I : collection of querying servants of the input cluster
• out_cluster: SocketAddr : socket address of the cluster to which the channel operates
• out_names: O : collection of replying servants of the output cluster
• max_ping: Duration : max ping duration for the channel
• size: Option<usize> : size of the channel (None for unlimited)
• P : type of path
• I : type of the collection of querying servants
• O : type of the collection of replying servants
• Output: completed starter builder or error

pub fn add_net_broadcast<P, I, O>( self, path: P, name: String, in_cluster: SocketAddr, in_names: I, out_cluster: SocketAddr, out_names: O, max_ping: Duration, size: usize, ) -> Result<Self, String>

where P: AsRef<Path>, I: IntoIterator<Item = String>, O: IntoIterator<Item = String>,

Add a new intercluster broadcast channel to starters builder

• path: P : path of the file where channel is serialized
• name: String : name of the channel
• in_cluster: SocketAddr : socket address of the cluster from which the channel operates
• in_names: I : collection of querying servants of the input cluster
• out_cluster: SocketAddr : socket address of the cluster to which the channel operates
• out_names: O : collection of replying servants of the output cluster
• max_ping: Duration : max ping duration for the channel
• size: usize : size of the channel
• P : type of path
• I : type of the collection of querying servants
• O : type of the collection of replying servants
• Output: completed starter builder or error

pub fn done(self) -> HashMap<SocketAddr, RecFiled<FiledStarter>>

Finalize the starters builder and get the list of starters definitions

• Output: a collection which maps from cluster socket address to starter definition

pub fn done_right( self, ) -> Result<HashMap<SocketAddr, RecFiled<FiledStarter>>, String>

Finalize the starters builder and get the list of starters definitions

• Some coherence tests are done
• Output: a collection which maps from cluster socket address to starter definition