Struct CompositeDelegate

pub struct CompositeDelegate<I, A, M = DefaultMergeDelegate<I, A>, R = NoopReconnectDelegate<I, A>, T = LpeTransfromDelegate<I, A>> { /* private fields */ }

CompositeDelegate is a helpful struct to split the Delegate into multiple small delegates, so that users do not need to implement full Delegate when they only want to custom some methods in the Delegate.

Implementations

impl<I, A> CompositeDelegate<I, A>

pub fn new() -> Self

Returns a new CompositeDelegate.

impl<I, A, M, R, T> CompositeDelegate<I, A, M, R, T>

where M: MergeDelegate<Id = I, Address = A>,

pub fn with_merge_delegate<NM>( self, merge: NM, ) -> CompositeDelegate<I, A, NM, R, T>

Set the MergeDelegate for the CompositeDelegate.

impl<I, A, M, R, T> CompositeDelegate<I, A, M, R, T>

pub fn with_reconnect_delegate<NR>( self, reconnect: NR, ) -> CompositeDelegate<I, A, M, NR, T>

Set the ReconnectDelegate for the CompositeDelegate.

impl<I, A, M, R, T> CompositeDelegate<I, A, M, R, T>

pub fn with_transform_delegate<NT>( self, transform: NT, ) -> CompositeDelegate<I, A, M, R, NT>

Set the TransformDelegate for the CompositeDelegate.

Trait Implementations

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

fn default() -> Self

Returns the “default value” for a type.

impl<I, A, M, R, T> Delegate for CompositeDelegate<I, A, M, R, T>

where I: Id, A: CheapClone + Send + Sync + 'static, M: MergeDelegate<Id = I, Address = A>, R: ReconnectDelegate<Id = I, Address = A>, T: TransformDelegate<Id = I, Address = A>,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

impl<I, A, M, R, T> MergeDelegate for CompositeDelegate<I, A, M, R, T>

where I: Id, A: CheapClone + Send + Sync + 'static, M: MergeDelegate<Id = I, Address = A>, R: Send + Sync + 'static, T: Send + Sync + 'static,

type Error = <M as MergeDelegate>::Error

The error type of the delegate

type Id = <M as MergeDelegate>::Id

The id type of the delegate

type Address = <M as MergeDelegate>::Address

The address type of the delegate

async fn notify_merge( &self, members: TinyVec<Member<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, M, R, T> ReconnectDelegate for CompositeDelegate<I, A, M, R, T>

where I: Id, A: CheapClone + Send + Sync + 'static, M: Send + Sync + 'static, R: ReconnectDelegate<Id = I, Address = A>, T: Send + Sync + 'static,

type Id = <R as ReconnectDelegate>::Id

The id type of the delegate

type Address = <R as ReconnectDelegate>::Address

The address type of the delegate

fn reconnect_timeout( &self, member: &Member<Self::Id, Self::Address>, timeout: Duration, ) -> Duration

Returns the reconnect timeout for the given member.

impl<I, A, M, R, T> TransformDelegate for CompositeDelegate<I, A, M, R, T>

where I: Id, A: CheapClone + Send + Sync + 'static, M: Send + Sync + 'static, R: Send + Sync + 'static, T: TransformDelegate<Id = I, Address = A>,

type Error = <T as TransformDelegate>::Error

The error type for the transformation.

type Id = <T as TransformDelegate>::Id

The Id type.

type Address = <T as TransformDelegate>::Address

The Address type.

fn encode_filter(filter: &Filter<Self::Id>) -> Result<Bytes, Self::Error>

Encodes the filter into bytes.

fn decode_filter(bytes: &[u8]) -> Result<(usize, Filter<Self::Id>), Self::Error>

Decodes the filter from the given bytes, returning the number of bytes consumed and the filter.

fn node_encoded_len(node: &Node<Self::Id, Self::Address>) -> usize

Returns the encoded length of the node.

fn encode_node( node: &Node<Self::Id, Self::Address>, dst: &mut [u8], ) -> Result<usize, Self::Error>

Encodes the node into the given buffer, returning the number of bytes written.

fn decode_node( bytes: impl AsRef<[u8]>, ) -> Result<(usize, Node<Self::Id, Self::Address>), Self::Error>

Decodes Node from the given bytes, returning the number of bytes consumed and the node.

fn id_encoded_len(id: &Self::Id) -> usize

Returns the encoded length of the id.

fn encode_id(id: &Self::Id, dst: &mut [u8]) -> Result<usize, Self::Error>

Encodes the id into the given buffer, returning the number of bytes written.

fn decode_id(bytes: &[u8]) -> Result<(usize, Self::Id), Self::Error>

Decodes the id from the given bytes, returning the number of bytes consumed and the id.

fn address_encoded_len(address: &Self::Address) -> usize

Returns the encoded length of the address.

fn encode_address( address: &Self::Address, dst: &mut [u8], ) -> Result<usize, Self::Error>

Encodes the address into the given buffer, returning the number of bytes written.

fn decode_address(bytes: &[u8]) -> Result<(usize, Self::Address), Self::Error>

Decodes the address from the given bytes, returning the number of bytes consumed and the address.

fn coordinate_encoded_len(coordinate: &Coordinate) -> usize

Encoded length of the coordinate.

fn encode_coordinate( coordinate: &Coordinate, dst: &mut [u8], ) -> Result<usize, Self::Error>

Encodes the coordinate into the given buffer, returning the number of bytes written.

fn decode_coordinate(bytes: &[u8]) -> Result<(usize, Coordinate), Self::Error>

Decodes the coordinate from the given bytes, returning the number of bytes consumed and the coordinate.

fn tags_encoded_len(tags: &Tags) -> usize

Encoded length of the tags.

fn encode_tags(tags: &Tags, dst: &mut [u8]) -> Result<usize, Self::Error>

Encodes the tags into the given buffer, returning the number of bytes written.

fn decode_tags(bytes: &[u8]) -> Result<(usize, Tags), Self::Error>

Decodes the tags from the given bytes, returning the number of bytes consumed and the tags.

fn message_encoded_len(msg: impl AsMessageRef<Self::Id, Self::Address>) -> usize

Encoded length of the message.

fn encode_message( msg: impl AsMessageRef<Self::Id, Self::Address>, dst: impl AsMut<[u8]>, ) -> Result<usize, Self::Error>

Encodes the message into the given buffer, returning the number of bytes written.

fn decode_message( ty: MessageType, bytes: impl AsRef<[u8]>, ) -> Result<(usize, SerfMessage<Self::Id, Self::Address>), Self::Error>

Decodes the message from the given bytes, returning the number of bytes consumed and the message.