Struct RestClusterNode

pub struct RestClusterNode { /* private fields */ }

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.

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 Hash for RestClusterNode

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

Feeds this value into the given Hasher.

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

where H: Hasher, Self: Sized,

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 Self: 'async_trait, 'life0: 'async_trait,

send message to the node

fn node_id(&self) -> &String

unique node identifier

fn service_instance_id(&self) -> &String

Provide implementation to get id provided by service discovery provider(e.g. Kubernetes). By default this function is an alias to Self::node_id

impl PartialEq for RestClusterNode

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for RestClusterNode