Enum libp2p::gossipsub::GossipsubEvent

source · [−]

pub enum GossipsubEvent {
    Message {
        propagation_source: PeerId,
        message_id: MessageId,
        message: GossipsubMessage,
    },
    Subscribed {
        peer_id: PeerId,
        topic: TopicHash,
    },
    Unsubscribed {
        peer_id: PeerId,
        topic: TopicHash,
    },
}

Expand description

Event that can be emitted by the gossipsub behaviour.

Variants

`Message`

Fields

propagation_source: PeerId

The peer that forwarded us this message.

message_id: MessageId

The MessageId of the message. This should be referenced by the application when validating a message (if required).

message: GossipsubMessage

The decompressed message itself.

A message has been received.

`Subscribed`

Fields

peer_id: PeerId

Remote that has subscribed.

topic: TopicHash

The topic it has subscribed to.

A remote subscribed to a topic.

`Unsubscribed`

Fields

peer_id: PeerId

Remote that has unsubscribed.

topic: TopicHash

The topic it has subscribed from.

A remote unsubscribed from a topic.

Trait Implementations

source

impl Debug for GossipsubEvent

source

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl RefUnwindSafe for GossipsubEvent

impl Send for GossipsubEvent

impl Sync for GossipsubEvent

impl Unpin for GossipsubEvent

pub fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

source

Enum libp2p::gossipsub::GossipsubEvent

Variants

`Message`

Fields

`Subscribed`

Fields

`Unsubscribed`

Fields

Trait Implementations

impl Debug for GossipsubEvent

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

Auto Trait Implementations

impl RefUnwindSafe for GossipsubEvent

impl Send for GossipsubEvent

impl Sync for GossipsubEvent

impl Unpin for GossipsubEvent

impl UnwindSafe for GossipsubEvent

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where
T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where
T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where
U: From<T>,

pub fn into(self) -> U

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

pub fn vzip(self) -> V

Enum libp2p::gossipsub::GossipsubEvent

Variants

Message

Fields

Subscribed

Fields

Unsubscribed

Fields

Trait Implementations

impl Debug for GossipsubEvent

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

Auto Trait Implementations

impl RefUnwindSafe for GossipsubEvent

impl Send for GossipsubEvent

impl Sync for GossipsubEvent

impl Unpin for GossipsubEvent

impl UnwindSafe for GossipsubEvent

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

`Message`

`Subscribed`

`Unsubscribed`

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,