Struct cluster_mode::RestClusterNode

pub struct RestClusterNode { /* fields omitted */ }

An implementation of almost_raft::Node

RestClusterNode uses REST API to communicate with other cluster nodes. User of the crate must provide the following endpoints

• /cluster/raft/request-vote/{requester_node_id:string}/{term:uint32}
• /cluster/raft/vote/{term:uint32}/{true|false}
• /cluster/raft/beat/{leader_node_id:string}/{term:uint32}

Implementations

impl RestClusterNode

pub fn new(node_id: String, instance: ServiceInstance) -> Self

Create new instance

Arguments

• node_id - Unique identifier, better be UUID
• instance - ServiceInstance of the node

pub fn service_instance(&self) -> &ServiceInstance

Get the instance represented by discovery service

Trait Implementations

impl Clone for RestClusterNode

fn clone(&self) -> RestClusterNode

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RestClusterNode

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

Formats the value using the given formatter.

impl Eq for RestClusterNode

impl Hash for RestClusterNode

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

pub fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl Node for RestClusterNode

type NodeType = RestClusterNode

concrete node type

fn send_message<'life0, 'async_trait>(
    &'life0 self,
    msg: Message<Self::NodeType>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

send message to the node

fn node_id(&self) -> &String

unique node identifier

impl PartialEq<RestClusterNode> for RestClusterNode

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

#[must_use]

pub fn ne(&self, other: &Rhs) -> bool

This method tests for !=.