pub struct Probe { /* private fields */ }Expand description
Probe functionality builder.
The builder holds information about this node’s own addresses and the configuration for the probing process. It is then used to construct the probing process itself.
Implementations§
Source§impl Probe
impl Probe
pub fn new(me: (OffchainPublicKey, Address), cfg: ProbeConfig) -> Self
Sourcepub async fn continuously_scan<T, U, V, W, C, Up>(
self,
api: (T, U),
manual_events: V,
store: W,
db: C,
move_up: Up,
) -> HashMap<HoprProbeProcess, AbortHandle>where
T: Sink<(ApplicationData, ResolvedTransportRouting, PacketSendFinalizer)> + Clone + Send + Sync + 'static,
T::Error: Send,
U: Stream<Item = (HoprPseudonym, ApplicationData)> + Send + Sync + 'static,
W: PeerDiscoveryFetch + ProbeStatusUpdate + Clone + Send + Sync + 'static,
C: DbOperations + Debug + Clone + Send + Sync + 'static,
V: Stream<Item = (PeerId, PingQueryReplier)> + Send + Sync + 'static,
Up: Sink<(HoprPseudonym, ApplicationData)> + Clone + Send + Sync + 'static,
pub async fn continuously_scan<T, U, V, W, C, Up>(
self,
api: (T, U),
manual_events: V,
store: W,
db: C,
move_up: Up,
) -> HashMap<HoprProbeProcess, AbortHandle>where
T: Sink<(ApplicationData, ResolvedTransportRouting, PacketSendFinalizer)> + Clone + Send + Sync + 'static,
T::Error: Send,
U: Stream<Item = (HoprPseudonym, ApplicationData)> + Send + Sync + 'static,
W: PeerDiscoveryFetch + ProbeStatusUpdate + Clone + Send + Sync + 'static,
C: DbOperations + Debug + Clone + Send + Sync + 'static,
V: Stream<Item = (PeerId, PingQueryReplier)> + Send + Sync + 'static,
Up: Sink<(HoprPseudonym, ApplicationData)> + Clone + Send + Sync + 'static,
The main function that assembles and starts the probing process.
Auto Trait Implementations§
impl Freeze for Probe
impl RefUnwindSafe for Probe
impl Send for Probe
impl Sync for Probe
impl Unpin for Probe
impl UnwindSafe for Probe
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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