Struct rings_core::message::MessageHandler

pub struct MessageHandler { /* private fields */ }

MessageHandler will manage resources.

Implementations

impl MessageHandler

pub fn new( dht: Arc<PeerRing>, callback: Option<CallbackFn>, validator: Option<ValidatorFn> ) -> Self

Create a new MessageHandler Instance.

pub fn handle_message<'life0, 'life_self, 'async_recursion>( &'life_self self, payload: &'life0 MessagePayload<Message> ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_recursion>>where 'life0: 'async_recursion, 'life_self: 'async_recursion,

Handle builtin message.

Trait Implementations

impl Clone for MessageHandler

fn clone(&self) -> MessageHandler

Returns a copy of the value.

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

Performs copy-assignment from source.

impl HandleMsg<ConnectNodeReport> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 ConnectNodeReport ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<ConnectNodeSend> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 ConnectNodeSend ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<CustomMessage> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, _: &'life2 CustomMessage ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<FindSuccessorReport> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 FindSuccessorReport ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<FindSuccessorSend> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 FindSuccessorSend ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<FoundVNode> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 FoundVNode ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<JoinDHT> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 JoinDHT ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<LeaveDHT> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 LeaveDHT ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<NotifyPredecessorReport> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 NotifyPredecessorReport ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<NotifyPredecessorSend> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload<Message>, msg: &'life2 NotifyPredecessorSend ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<SearchVNode> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 SearchVNode ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Search VNode via successor If a VNode is storead local, it will response immediately.(See Chordstorageinterface::storage_fetch)

impl HandleMsg<SyncVNodeWithSuccessor> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 SyncVNodeWithSuccessor ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl HandleMsg<VNodeOperation> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 MessagePayload<Message>, msg: &'life2 VNodeOperation ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageHandlerEvent>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.