Struct connect::Cluster

pub struct Cluster { /* fields omitted */ }

Cluster represents a group of servers in a distributed system.

Methods

impl Cluster

pub fn with_file(path: &str) -> Cluster

This function takes file_path as input and initializes Cluster with the file.

Panics

This function panics if it is not able to find a file on file_path or if it does not have permissions to access the file. Also, this function panics if there is any [ConfigError] or some configuration values are malformed or absent.

pub fn get_local_peer_addr(&self) -> SocketAddr

This function returns SocketAddr for peer connection.

pub fn get_local_client_addr(&self) -> SocketAddr

This function returns SocketAddr for client connection.

pub fn get_remote_peer_addrs(&self) -> Vec<SocketAddr>

This function returns a vector containing SocketAddr for peer connection for all remote nodes of this cluster.

pub fn get_remote_client_addrs(&self) -> Vec<SocketAddr>

This function returns a vector containing SocketAddr for client connection for all remote nodes of this cluster.

pub fn get_remote_peer_ids(&self) -> Vec<NodeId>

This function returns a vector containing NodeId of all the remote nodes of this cluster.

pub fn get_peer_addr(&self, member_id: &NodeId) -> Option<SocketAddr>

This function returns SocketAddr for peer connection for peer with specified member_id.

pub fn get_client_addr(&self, member_id: &NodeId) -> Option<SocketAddr>

This function returns SocketAddr for client connection for peer with specified member_id.

Trait Implementations

impl Debug for Cluster

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a> From<&'a Config> for Cluster

fn from(config: &'a Config) -> Cluster

This function performs conversion from Config to Cluster.

Panics

This function panics if there is any ConfigError or some configuration values are malformed or absent.