Struct kitsune_p2p::actor::RpcMulti

pub struct RpcMulti {
    pub space: Arc<KitsuneSpace>,
    pub basis: Arc<KitsuneBasis>,
    pub payload: Vec<u8>,
    pub max_remote_agent_count: u8,
    pub max_timeout: KitsuneTimeout,
    pub remote_request_grace_ms: u64,
}

Make a request to multiple destination agents - awaiting/aggregating the responses. The remote sides will see these messages as “RequestEvt” events.

Fields

space: Arc<KitsuneSpace>

The “space” context.

basis: Arc<KitsuneBasis>

The “basis” hash/coordinate of destination neigborhood.

payload: Vec<u8>

Request data.

max_remote_agent_count: u8

Max number of remote requests to make

max_timeout: KitsuneTimeout

Max timeout for aggregating response data

remote_request_grace_ms: u64

Remote request grace period. If we already have results from other sources, but made any additional outgoing remote requests, we’ll wait at least this long for additional responses.

Implementations

impl RpcMulti

pub fn new(
    tuning_params: &KitsuneP2pTuningParams,
    space: Arc<KitsuneSpace>,
    basis: Arc<KitsuneBasis>,
    payload: Vec<u8>
) -> Self

Construct a new RpcMulti input struct with timing defaults specified by tuning_params.

Trait Implementations

impl Clone for RpcMulti

fn clone(&self) -> RpcMulti

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RpcMulti

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.