Struct Node 

pub struct Node { /* private fields */ }

Implementations

impl Node

pub async fn insert_edge_connection_middleware<M>(&self, middleware: M)

where M: EdgeConnectionMiddleware<EdgeConnectionHandlerObject>,

Insert a middleware to the edge connection handler.

Middlewares may be used to intercept and modify the behavior of the edge connection handler, such as logging, authentication, etc.

Refer to the EdgeConnectionMiddleware trait for more information.

pub async fn get_edge_connection_handler(&self) -> EdgeConnectionHandlerObject

Get the current edge connection handler.

You may access the Node::edge_handler field directly to get the lock.

pub async fn set_edge_connection_handler( &self, handler: EdgeConnectionHandlerObject, )

Set the edge connection handler.

impl Node

pub async fn raft(&self) -> Raft<TypeConfig>

Get the inner openraft structure

pub fn config(&self) -> &NodeConfig

Get node config

pub fn new(config: NodeConfig) -> Self

Create a new node

pub async fn start<C: ClusterProvider>( &self, cluster_provider: C, ) -> Result<(), Error>

Start running, this will start tcp connection service and node discovery service

pub async fn load_from_durable_service(&self) -> Result<(), Error>

load existed topic from durable service

pub fn raft_opt(&self) -> Option<Raft<TypeConfig>>

pub fn node_ref(&self) -> NodeRef

Get a weak reference of this node

pub async fn create_edge_connection<C: EdgeNodeConnection>( &self, conn: C, edge_config: EdgeConfig, ) -> Result<NodeId, EdgeConnectionError>

Create a connection to a edge node.

pub fn id(&self) -> NodeId

pub fn is(&self, id: NodeId) -> bool

pub fn get_edge_connection(&self, to: NodeId) -> Option<EdgeConnectionRef>

pub async fn remove_edge_connection(&self, to: NodeId)

pub async fn check_ep_auth( &self, ep: &EndpointAddr, peer: &NodeId, ) -> Result<(), EdgeError>

pub async fn is_leader(&self) -> bool

pub async fn wait_for_leader(&self) -> Result<(), Error>

pub async fn load_topic<C: Into<TopicConfig>>( &self, config: C, queue: Vec<DurableMessage>, ) -> Result<(), Error>

pub async fn create_new_topic<C: Into<TopicConfig>>( &self, config: C, ) -> Result<()>

pub async fn set_wait_ack(&self, id: MessageId) -> WaitAckHandle

Create the wait handle of a specific message

pub async fn send_message( &self, topic: TopicCode, message: Message, ) -> Result<WaitAckHandle, Error>

Send a message out, and get a awaitable handle.

pub async fn snapshot_data(&self) -> Result<NodeData, Error>

Methods from Deref<Target = NodeInner>

pub async fn shutdown(&self)

Trait Implementations

impl Clone for Node

fn clone(&self) -> Node

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Node

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

Formats the value using the given formatter.

impl Deref for Node

type Target = NodeInner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.