Struct VoidDelegate 

pub struct VoidDelegate<I, A>(/* private fields */);

Void delegate

Implementations

impl<I, A> VoidDelegate<I, A>

pub const fn new() -> Self

Creates a new VoidDelegate.

Trait Implementations

impl<I, A> AliveDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Error = VoidDelegateError

The error type of the delegate

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn notify_alive( &self, _peer: Arc<NodeState<Self::Id, Self::Address>>, ) -> Result<(), Self::Error>

Invoked when a message about a live node is received from the network. Returning a non-nil error prevents the node from being considered a peer.

impl<I: Clone, A: Clone> Clone for VoidDelegate<I, A>

fn clone(&self) -> VoidDelegate<I, A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I, A> ConflictDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn notify_conflict( &self, _existing: Arc<NodeState<Self::Id, Self::Address>>, _other: Arc<NodeState<Self::Id, Self::Address>>, )

Invoked when a name conflict is detected

impl<I: Copy, A: Copy> Copy for VoidDelegate<I, A>

impl<I: Debug, A: Debug> Debug for VoidDelegate<I, A>

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

Formats the value using the given formatter.

impl<I, A> Default for VoidDelegate<I, A>

fn default() -> Self

Returns the “default value” for a type.

impl<I, A> Delegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

impl<I, A> EventDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn notify_join(&self, _node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have joined the cluster

async fn notify_leave(&self, _node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have left the cluster

async fn notify_update(&self, _node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have updated, usually involving the meta data.

impl<I, A> MergeDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Error = VoidDelegateError

The error type of the delegate

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn notify_merge( &self, _peers: Arc<[NodeState<Self::Id, Self::Address>]>, ) -> Result<(), Self::Error>

Invoked when a merge could take place. Provides a list of the nodes known by the peer. If the return value is Err, the merge is canceled.

impl<I, A> NodeDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

async fn node_meta(&self, _limit: usize) -> Meta

Used to retrieve meta-data about the current node when broadcasting an alive message. It’s length is limited to the given byte size. This metadata is available in the NodeState structure.

async fn notify_message(&self, _msg: Cow<'_, [u8]>)

Called when a user-data message is received. Care should be taken that this method does not block, since doing so would block the entire UDP packet receive loop. Additionally, the byte slice may be modified after the call returns, so it should be copied if needed

async fn broadcast_messages<F>( &self, _limit: usize, _encoded_len: F, ) -> impl Iterator<Item = Bytes> + Send

where F: Fn(Bytes) -> (usize, Bytes) + Send,

Called when user data messages can be broadcast. It can return a list of buffers to send. Each buffer should assume an overhead as provided with a limit on the total byte size allowed. The total byte size of the resulting data to send must not exceed the limit. Care should be taken that this method does not block, since doing so would block the entire UDP packet receive loop.

async fn local_state(&self, _join: bool) -> Bytes

Used for a TCP Push/Pull. This is sent to the remote side in addition to the membership information. Any data can be sent here. See merge_remote_state as well. The join boolean indicates this is for a join instead of a push/pull.

async fn merge_remote_state(&self, _buf: &[u8], _join: bool)

Invoked after a TCP Push/Pull. This is the state received from the remote side and is the result of the remote side’s local_state call. The ‘join’ boolean indicates this is for a join instead of a push/pull.

impl<I, A> PingDelegate for VoidDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn ack_payload(&self) -> Bytes

Invoked when an ack is being sent; the returned bytes will be appended to the ack

async fn notify_ping_complete( &self, _node: Arc<NodeState<Self::Id, Self::Address>>, _rtt: Duration, _payload: Bytes, )

Invoked when an ack for a ping is received

fn disable_reliable_pings(&self, _target: &Self::Id) -> bool

Invoked when we want to send a ping message to target by promised connection. Return true if the target node does not expect ping message from promised connection.