Enum DiscoveryOut

Source

pub enum DiscoveryOut {
    Discovered(PeerId),
    UnroutablePeer(PeerId),
    ValueFound(PeerRecord, Duration),
    PutRecordRequest(RecordKey, Vec<u8>, Option<PeerId>, Option<Instant>),
    ValueNotFound(RecordKey, Duration),
    ValuePut(RecordKey, Duration),
    ValuePutFailed(RecordKey, Duration),
    RandomKademliaStarted,
}

Expand description

Event generated by the DiscoveryBehaviour.

Variants§

§

Discovered(PeerId)

A connection to a peer has been established but the peer has not been added to the routing table because BucketInserts::Manual is configured. If the peer is to be included in the routing table, it must be explicitly added via DiscoveryBehaviour::add_self_reported_address.

§

UnroutablePeer(PeerId)

A peer connected to this node for whom no listen address is known.

In order for the peer to be added to the Kademlia routing table, a known listen address must be added via DiscoveryBehaviour::add_self_reported_address, e.g. obtained through the identify protocol.

§

ValueFound(PeerRecord, Duration)

The DHT yielded results for the record request.

Returning the result grouped in (key, value) pairs as well as the request duration.

§

PutRecordRequest(RecordKey, Vec<u8>, Option<PeerId>, Option<Instant>)

The DHT received a put record request.

§

ValueNotFound(RecordKey, Duration)

The record requested was not found in the DHT.

Returning the corresponding key as well as the request duration.

§

ValuePut(RecordKey, Duration)

The record with a given key was successfully inserted into the DHT.

Returning the corresponding key as well as the request duration.

§

ValuePutFailed(RecordKey, Duration)

Inserting a value into the DHT failed.

Returning the corresponding key as well as the request duration.

§

RandomKademliaStarted

Started a random Kademlia query.

Only happens if DiscoveryConfig::with_dht_random_walk has been configured to true.

Enum DiscoveryOutCopy item path

Variants§

Discovered(PeerId)

UnroutablePeer(PeerId)

ValueFound(PeerRecord, Duration)

PutRecordRequest(RecordKey, Vec<u8>, Option<PeerId>, Option<Instant>)

ValueNotFound(RecordKey, Duration)

ValuePut(RecordKey, Duration)

ValuePutFailed(RecordKey, Duration)

RandomKademliaStarted

Trait Implementations§

impl Debug for DiscoveryOut

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

Auto Trait Implementations§

impl !Freeze for DiscoveryOut

impl RefUnwindSafe for DiscoveryOut

impl Send for DiscoveryOut

impl Sync for DiscoveryOut

impl Unpin for DiscoveryOut

impl UnwindSafe for DiscoveryOut

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<T> Any for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn type_name(&self) -> &'static str

impl<T> AnySync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

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

fn borrow(&self) -> &T

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

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

impl<T> CheckedConversion for T

fn checked_from<T>(t: T) -> Option<Self>where Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>where Self: TryInto<T>,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T, Outer> IsWrappedBy<Outer> for Twhere Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,

fn from_ref(outer: &Outer) -> &T

fn from_mut(outer: &mut Outer) -> &mut T

impl<T> Pointable for T

const ALIGN: usize = _

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T> SaturatedConversion for T

fn saturated_from<T>(t: T) -> Selfwhere Self: UniqueSaturatedFrom<T>,

fn saturated_into<T>(self) -> Twhere Self: UniqueSaturatedInto<T>,

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

type Error = Infallible

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

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

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

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

impl<S, T> UncheckedInto<T> for Swhere T: UncheckedFrom<S>,

fn unchecked_into(self) -> T

impl<T, S> UniqueSaturatedInto<T> for Swhere T: Bounded, S: TryInto<T>,

fn unique_saturated_into(self) -> T

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Enum DiscoveryOut

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

impl<T> Any for T
where T: Any,

impl<T> AnySync for T
where T: Any + Send + Sync,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

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

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

fn checked_from<T>(t: T) -> Option<Self>
where Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>
where Self: TryInto<T>,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, Outer> IsWrappedBy<Outer> for T
where Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,

fn saturated_from<T>(t: T) -> Self
where Self: UniqueSaturatedFrom<T>,

fn saturated_into<T>(self) -> T
where Self: UniqueSaturatedInto<T>,

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

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

impl<S, T> UncheckedInto<T> for S
where T: UncheckedFrom<S>,

impl<T, S> UniqueSaturatedInto<T> for S
where T: Bounded, S: TryInto<T>,

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

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> MaybeDebug for T
where T: Debug,

impl<T> MaybeRefUnwindSafe for T
where T: RefUnwindSafe,