Struct OverlayAdvertPayloadV0

pub struct OverlayAdvertPayloadV0 {
    pub overlay: OverlayId,
    pub session: SessionId,
    pub seq: u64,
    pub publishers: Vec<PublisherAdvert>,
    pub previous_session: Option<SessionId>,
    pub peer: DirectPeerId,
}

Overlay Advert Payload V0

Fields

overlay: OverlayId

the target Overlay ID (cannot be an Outer overlay)

session: SessionId

the newly generated session ID the peer will use in this overlay All the revoked sessionIDs are kept locally by their initiator.

seq: u64

Current sequence number. For a new session, must be zero.

publishers: Vec<PublisherAdvert>

list of publisher currently registered on the peer. flooded in overlay (with this overlayAdvert) when first joining an overlay, so that subscription routing tables can be updated or sent in an OverlayAdvertMarker, to a specific new peer that just joined the overlay (in the point of view of the emitter) it can be left empty when a CoreBrokerConnect is made on a broker that is known to be already part of the overlay.

previous_session: Option<SessionId>

the previous session ID the peer was using in this overlay. Used to cleanup seq counters maintained in each other peer if the previous session is empty (because it is the first time broker joins this overlay) or if a remote peer doesn’t find this session kept locally, it is not an error. In the later case (if broker missed some intermediary sessions), the remote peer can ask the initiator peer if the last known session can be locally revoked with a ConfirmRevokedSession message (answered with yes or no)

peer: DirectPeerId

peer ID of the broker issuing this Advert

Trait Implementations

impl Clone for OverlayAdvertPayloadV0

fn clone(&self) -> OverlayAdvertPayloadV0

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OverlayAdvertPayloadV0

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OverlayAdvertPayloadV0

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OverlayAdvertPayloadV0

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

where __S: Serializer,

Serialize this value into the given Serde serializer.