Trait fedimint_core::query::QueryStrategy

pub trait QueryStrategy<IR, OR = IR> {
    // Required method
    fn process(
        &mut self,
        peer_id: PeerId,
        response: PeerResult<IR>
    ) -> QueryStep<OR>;

    // Provided methods
    fn request_timeout(&self) -> Option<Duration> { ... }
    fn with_request_timeout(
        self,
        timeout: Duration
    ) -> QueryStrategyWithRequestTimeout<Self, IR, OR>
       where Self: Sized { ... }
}

Fedimint query strategy

Due to federated security model each Fedimint client API call to the Federation might require a different way to process one or more required responses from the Federation members. This trait abstracts away the details of each specific strategy for the generic client Api code.

Required Methods

fn process( &mut self, peer_id: PeerId, response: PeerResult<IR> ) -> QueryStep<OR>

Provided Methods

fn request_timeout(&self) -> Option<Duration>

Should requests for this strategy have specific timeouts?

fn with_request_timeout( self, timeout: Duration ) -> QueryStrategyWithRequestTimeout<Self, IR, OR>

where Self: Sized,

Implementors

impl QueryStrategy<SupportedApiVersionsSummary, ApiVersionSet> for DiscoverApiVersionSet

impl<IR, OR, S> QueryStrategy<IR, OR> for QueryStrategyWithRequestTimeout<S, IR, OR>

where S: QueryStrategy<IR, OR>,

impl<R> QueryStrategy<R, BTreeMap<PeerId, R>> for AllOrDeadline<R>

impl<R: Eq + Clone + Debug> QueryStrategy<R> for ThresholdConsensus<R>

impl<R: Eq + Clone + Debug, T> QueryStrategy<R, BTreeMap<PeerId, T>> for FilterMapThreshold<R, T>

impl<R: Debug + Eq + Clone> QueryStrategy<Vec<R>> for UnionResponses<R>

impl<R: Debug + Eq + Clone> QueryStrategy<R, Vec<R>> for UnionResponsesSingle<R>

impl<R: Debug + Eq + Clone, T> QueryStrategy<R, T> for FilterMap<R, T>