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,
    },
    GossipsubNotSupported {
        peer_id: PeerId,
    },
}

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.

`GossipsubNotSupported`

Fields

peer_id: PeerId

A peer that does not support gossipsub has connected.

Trait Implementations

impl Debug for GossipsubEvent

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

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

impl UnwindSafe for GossipsubEvent

Blanket Implementations

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

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

const: unstable · source

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Returns the argument unchanged.

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

const: unstable · source

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.

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> 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<U>>::Error>

Performs the conversion.

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

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

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

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

pub fn vzip(self) -> V

impl<T> Erased for T