pub struct Discovery { /* private fields */ }Expand description
Confidential topic discovery and random-walk strategy to resolve transport infos.
§Design
Read more about the underlying design in p2panda-discovery.
Implementations§
Source§impl Discovery
impl Discovery
pub fn builder(address_book: AddressBook, endpoint: Endpoint) -> Builder
Sourcepub async fn events(&self) -> Result<Receiver<DiscoveryEvent>, DiscoveryError>
pub async fn events(&self) -> Result<Receiver<DiscoveryEvent>, DiscoveryError>
Subscribe to system events.
Sourcepub async fn metrics(&self) -> Result<DiscoveryMetrics, DiscoveryError>
pub async fn metrics(&self) -> Result<DiscoveryMetrics, DiscoveryError>
Returns current metrics.
Trait Implementations§
Source§impl ChildActor for Discovery
impl ChildActor for Discovery
fn on_start( &self, supervisor: ActorCell, thread_pool: ThreadLocalActorSpawner, ) -> ChildActorFut<'_>
Auto Trait Implementations§
impl Freeze for Discovery
impl !RefUnwindSafe for Discovery
impl Send for Discovery
impl Sync for Discovery
impl Unpin for Discovery
impl !UnwindSafe for Discovery
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> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage