Struct MarshalResolver 

pub struct MarshalResolver<D: Digest, P: PublicKey> { /* private fields */ }

Store-backed resolver for Commonware marshal requests.

Unlike the P2P resolver, this resolves marshal backfill requests directly from an Exoware Simplex store and delivers responses into Marshal’s local resolver handler.

Implementations

impl<D, P> MarshalResolver<D, P>

where D: Digest + Send + 'static, P: PublicKey,

pub fn init<E>( context: E, mailbox_size: NonZeroUsize, client: SimplexClient, ) -> (Receiver<D>, Self)

where E: Clock + Metrics + Spawner,

pub fn new<E>( context: E, mailbox_size: NonZeroUsize, client: SimplexClient, handler: MarshalHandler<D>, ) -> Self

where E: Clock + Metrics + Spawner,

pub const fn client(&self) -> &SimplexClient

pub fn into_client(self) -> SimplexClient

Trait Implementations

impl<D: Clone + Digest, P: Clone + PublicKey> Clone for MarshalResolver<D, P>

fn clone(&self) -> MarshalResolver<D, P>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<D, P> Resolver for MarshalResolver<D, P>

where D: Digest + Send + 'static, P: PublicKey,

type Key = Key<D>

Type used to key data requested from peers.

type Subscriber = Annotation

Type used to track subscribers on fetch keys.

fn fetch<F>(&mut self, key: F) -> Feedback

where F: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

Initiate a fetch.

fn fetch_all<F>(&mut self, keys: Vec<F>) -> Feedback

where F: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

Initiate fetches for a batch of keys.

fn retain( &mut self, predicate: impl Fn(&Self::Key, &Self::Subscriber) -> bool + Send + 'static, ) -> Feedback

Retain only fetch subscribers satisfying the predicate.

impl<D, P> TargetedResolver for MarshalResolver<D, P>

where D: Digest + Send + 'static, P: PublicKey,

type PublicKey = P

Type used to identify peers for targeted fetch hints.

fn fetch_targeted( &mut self, key: impl Into<Fetch<Self::Key, Self::Subscriber>> + Send, targets: NonEmptyVec<Self::PublicKey>, ) -> Feedback

Initiate a fetch with target peer hints.

fn fetch_all_targeted<F>( &mut self, keys: Vec<(F, NonEmptyVec<Self::PublicKey>)>, ) -> Feedback

where F: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

Initiate fetches for multiple keys, each with their own target hints.