Struct discv5::query_pool::Query

pub struct Query<TTarget, TNodeId, TResult> {
    id: QueryId,
    peer_iter: QueryPeerIter<TTarget, TNodeId, TResult>,
    started: Option<Instant>,
    target: TTarget,
}

A query in a QueryPool.

Fields

id: QueryId

The unique ID of the query.

peer_iter: QueryPeerIter<TTarget, TNodeId, TResult>

The peer iterator that drives the query state.

started: Option<Instant>

The instant when the query started (i.e. began waiting for the first result from a peer).

target: TTarget

Target we are looking for.

Implementations

impl<TTarget, TNodeId, TResult> Query<TTarget, TNodeId, TResult> where
    TTarget: Into<Key<TTarget>> + Clone,
    TNodeId: Into<Key<TNodeId>> + Eq + Clone,
    TResult: Into<TNodeId> + Clone, 

fn new(
    id: QueryId,
    peer_iter: QueryPeerIter<TTarget, TNodeId, TResult>,
    target: TTarget
) -> Self

Creates a new query without starting it.

pub fn id(&self) -> QueryId

Gets the unique ID of the query.

pub fn on_failure(&mut self, peer: &TNodeId)

Informs the query that the attempt to contact peer failed.

pub fn on_success<'a>(&mut self, peer: &TNodeId, new_peers: &'a [TResult]) where
    &'a TResult: Into<TNodeId>, 

Informs the query that the attempt to contact peer succeeded, possibly resulting in new peers that should be incorporated into the query, if applicable.

fn next(&mut self, now: Instant) -> QueryState<TNodeId>

Advances the state of the underlying peer iterator.

pub fn into_result(self) -> QueryResult<TTarget, impl Iterator<Item = TNodeId>>

Consumes the query, producing the final QueryResult.

pub fn target(&self) -> &TTarget

Returns a reference to the query target.

pub fn target_mut(&mut self) -> &mut TTarget

Returns a mutable reference to the query target.