Struct NodeServer 

pub struct NodeServer { /* private fields */ }

Implementations

impl NodeServer

pub fn new(node: Node, config: Config) -> Self

pub fn get_successor(&self) -> Node

pub fn get_successor_list(&self) -> Vec<Node>

pub fn set_successor_list(&self, succ_list: Vec<Node>)

pub fn get_predecessor(&self) -> Option<Node>

pub fn set_predecessor(&self, node: Option<Node>)

pub async fn start( &mut self, join_node: Option<Node>, ) -> DhtResult<ServerManager>

Start the server Returns if the listener starts

pub fn finger_table_start(&self, k: usize) -> u64

pub fn remove_connection(&self, node: &Node)

Remove broken connections

pub async fn join(&mut self, node: &Node) -> DhtResult<()>

pub async fn stabilize(&mut self)

pub async fn fix_finger(&mut self, index: usize)

Trait Implementations

impl Clone for NodeServer

fn clone(&self) -> NodeServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl NodeService for NodeServer

type GetNodeRpcFut = Pin<Box<dyn Future<Output = Node> + Send>>

The response future returned by NodeService::get_node_rpc.

type GetPredecessorRpcFut = Pin<Box<dyn Future<Output = Option<Node>> + Send>>

The response future returned by NodeService::get_predecessor_rpc.

type GetSuccessorRpcFut = Pin<Box<dyn Future<Output = Node> + Send>>

The response future returned by NodeService::get_successor_rpc.

type GetSuccessorListRpcFut = Pin<Box<dyn Future<Output = Vec<Node>> + Send>>

The response future returned by NodeService::get_successor_list_rpc.

type FindSuccessorListRpcFut = Pin<Box<dyn Future<Output = Vec<Node>> + Send>>

The response future returned by NodeService::find_successor_list_rpc.

type FindPredecessorRpcFut = Pin<Box<dyn Future<Output = Node> + Send>>

The response future returned by NodeService::find_predecessor_rpc.

type ClosestPrecedingFingerRpcFut = Pin<Box<dyn Future<Output = Node> + Send>>

The response future returned by NodeService::closest_preceding_finger_rpc.

type NotifyRpcFut = Pin<Box<dyn Future<Output = ()> + Send>>

The response future returned by NodeService::notify_rpc.

type StabilizeRpcFut = Pin<Box<dyn Future<Output = ()> + Send>>

The response future returned by NodeService::stabilize_rpc.

type GetLocalRpcFut = Pin<Box<dyn Future<Output = Option<Vec<u8>>> + Send>>

The response future returned by NodeService::get_local_rpc.

type SetLocalRpcFut = Pin<Box<dyn Future<Output = ()> + Send>>

The response future returned by NodeService::set_local_rpc.

type GetRpcFut = Pin<Box<dyn Future<Output = Option<Vec<u8>>> + Send>>

The response future returned by NodeService::get_rpc.

type SetRpcFut = Pin<Box<dyn Future<Output = ()> + Send>>

The response future returned by NodeService::set_rpc.

type ReplicateRpcFut = Pin<Box<dyn Future<Output = ()> + Send>>

The response future returned by NodeService::replicate_rpc.

fn get_node_rpc(self, _: Context) -> Pin<Box<dyn Future<Output = Node> + Send>>

fn get_predecessor_rpc( self, _: Context, ) -> Pin<Box<dyn Future<Output = Option<Node>> + Send>>

fn get_successor_rpc( self, _: Context, ) -> Pin<Box<dyn Future<Output = Node> + Send>>

fn get_successor_list_rpc( self, _: Context, ) -> Pin<Box<dyn Future<Output = Vec<Node>> + Send>>

fn find_successor_list_rpc( self, _: Context, id: Digest, ) -> Pin<Box<dyn Future<Output = Vec<Node>> + Send>>

fn find_predecessor_rpc( self, _: Context, id: Digest, ) -> Pin<Box<dyn Future<Output = Node> + Send>>

fn closest_preceding_finger_rpc( self, _: Context, id: Digest, ) -> Pin<Box<dyn Future<Output = Node> + Send>>

fn notify_rpc( self, _: Context, node: Node, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

fn stabilize_rpc(self, _: Context) -> Pin<Box<dyn Future<Output = ()> + Send>>

fn get_local_rpc( self, _: Context, key: Key, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send>>

fn set_local_rpc( self, _: Context, key: Key, value: Option<Value>, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

fn get_rpc( self, _: Context, key: Key, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send>>

fn set_rpc( self, _: Context, key: Key, value: Option<Value>, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

fn replicate_rpc( self, _: Context, key: Key, value: Option<Value>, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

fn serve(self) -> ServeNodeService<Self>

Returns a serving function to use with InFlightRequest::execute.