Struct P2pNetworkPubsubClientState

pub struct P2pNetworkPubsubClientState {
    pub protocol: BroadcastAlgorithm,
    pub addr: ConnectionAddr,
    pub outgoing_stream_id: Option<u32>,
    pub message: Rpc,
    pub cache: P2pNetworkPubsubRecentlyPublishCache,
    pub buffer: Vec<u8>,
    pub incoming_messages: Vec<Message>,
}

State of a pubsub client connected to a peer.

This struct maintains essential information about the client’s protocol, connection details, message buffers, and caching mechanisms. It facilitates efficient message handling and broadcasting within the pubsub system.

Fields

protocol: BroadcastAlgorithm

Broadcast algorithm used for this client.

addr: ConnectionAddr

Connection address of the peer.

outgoing_stream_id: Option<u32>

Outgoing stream identifier, if any.

• Some(StreamId): Indicates an active outgoing stream.
• None: No outgoing stream is currently established.

message: Rpc

Current RPC message being constructed or processed.

• subscriptions: List of subscription options for various topics.
• publish: Messages queued for publishing.
• control: Control commands for managing the mesh network.

cache: P2pNetworkPubsubRecentlyPublishCache

Cache of recently published messages.

buffer: Vec<u8>

Buffer for incoming data fragments.

Stores partial data received from peers, facilitating the assembly of complete messages when all fragments are received.

incoming_messages: Vec<Message>

Collection of incoming messages from the peer.

Holds fully decoded pb::Message instances received from the peer, ready for further handling such as validation, caching, and broadcasting.

Implementations

impl P2pNetworkPubsubClientState

pub fn publish(&mut self, message: &Message)

pub fn clear_buffer(&mut self)

pub fn clear_incoming(&mut self)

impl P2pNetworkPubsubClientState

pub fn message_is_empty(&self) -> bool

Trait Implementations

impl Clone for P2pNetworkPubsubClientState

fn clone(&self) -> P2pNetworkPubsubClientState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for P2pNetworkPubsubClientState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for P2pNetworkPubsubClientState

fn deserialize<__D>( __deserializer: __D, ) -> Result<P2pNetworkPubsubClientState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl MallocSizeOf for P2pNetworkPubsubClientState

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.

impl Serialize for P2pNetworkPubsubClientState

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.