pub struct SubMarkerV0 {
pub publisher: DirectPeerId,
pub topic: TopicId,
pub subscriber: DirectPeerId,
pub known_heads: Vec<ObjectId>,
}
Expand description
Topic subscription marker sent by all publishers, back to subscriber
Forwarded to all subscribers.
Fields§
§publisher: DirectPeerId
The publisher broker that marks its starting cut TODO: that could be omitted, because we can retrieve it with the SessionId
topic: TopicId
The subscribed topic
subscriber: DirectPeerId
The subscriber
known_heads: Vec<ObjectId>
Current heads at the broker when receiving the SubReq. Can be used to safely do a CoreTopicSyncReq
Trait Implementations§
Source§impl Clone for SubMarkerV0
impl Clone for SubMarkerV0
Source§fn clone(&self) -> SubMarkerV0
fn clone(&self) -> SubMarkerV0
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for SubMarkerV0
impl Debug for SubMarkerV0
Source§impl<'de> Deserialize<'de> for SubMarkerV0
impl<'de> Deserialize<'de> for SubMarkerV0
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for SubMarkerV0
impl RefUnwindSafe for SubMarkerV0
impl Send for SubMarkerV0
impl Sync for SubMarkerV0
impl Unpin for SubMarkerV0
impl UnwindSafe for SubMarkerV0
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more