Struct holochain::prelude::HostStub

pub struct HostStub { /* private fields */ }

Dummy host impl for plumbing

Implementations

impl HostStub

pub fn new() -> Arc<HostStub>

Constructor

pub fn with_check_op_data( check_op_data_impl: Box<dyn Fn(Arc<KitsuneSpace>, Vec<Arc<KitsuneOpHash>>, Option<FetchContext>) -> MustBoxFuture<'static, Result<Vec<bool>, Box<dyn Error + Send + Sync>>> + Send + Sync> ) -> Arc<HostStub>

Constructor

pub fn fail_next_request(&self)

Request that the next request will fail and respond with an error

pub fn get_fail_count(&self) -> usize

Get the count of requests that have failed due to fail_next_request.

Trait Implementations

impl Debug for HostStub

Manual implementation of debug to skip over underivable Debug field.

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

Formats the value using the given formatter.

impl FetchPoolConfig for HostStub

fn merge_fetch_contexts(&self, _a: u32, _b: u32) -> u32

When a fetch key is added twice, this determines how the two different contexts get reconciled.

fn item_retry_delay(&self) -> Duration

How long between successive item fetches, regardless of source? This gives a source a fair chance to respond before proceeding with a different source.

fn source_retry_delay(&self) -> Duration

How long between successive fetches from a particular source, for a particular item? This protects us from wasting resources on a source which may be offline. This will eventually be replaced with an exponential backoff which will be tracked for this source across all items.

impl KitsuneHost for HostStub

fn block( &self, input: Block ) -> MustBoxFuture<'_, Result<(), Box<dyn Error + Send + Sync>>>

We are requesting a block.

fn unblock( &self, input: Block ) -> MustBoxFuture<'_, Result<(), Box<dyn Error + Send + Sync>>>

We are requesting an unblock.

fn is_blocked( &self, input: BlockTargetId, timestamp: Timestamp ) -> MustBoxFuture<'_, Result<bool, Box<dyn Error + Send + Sync>>>

We want to know if a target is blocked.

fn get_agent_info_signed( &self, input: GetAgentInfoSignedEvt ) -> MustBoxFuture<'_, Result<Option<AgentInfoSigned>, Box<dyn Error + Send + Sync>>>

We need to get previously stored agent info.

fn remove_agent_info_signed( &self, input: GetAgentInfoSignedEvt ) -> MustBoxFuture<'_, Result<bool, Box<dyn Error + Send + Sync>>>

Remove an agent info from storage

fn peer_extrapolated_coverage( &self, space: Arc<KitsuneSpace>, dht_arc_set: DhtArcSet ) -> MustBoxFuture<'_, Result<Vec<f64>, Box<dyn Error + Send + Sync>>>

Extrapolated Peer Coverage.

fn query_region_set( &self, space: Arc<KitsuneSpace>, dht_arc_set: Arc<DhtArcSet> ) -> MustBoxFuture<'_, Result<RegionSetLtcs, Box<dyn Error + Send + Sync>>>

Query aggregate dht op data to form an LTCS set of region data.

fn query_size_limited_regions( &self, space: Arc<KitsuneSpace>, size_limit: u32, regions: Vec<Region> ) -> MustBoxFuture<'_, Result<Vec<Region>, Box<dyn Error + Send + Sync>>>

Given an input list of regions, return a list of equal or greater length such that each region’s size is less than the size_limit, by recursively subdividing regions which are over the size limit.

fn query_op_hashes_by_region( &self, space: Arc<KitsuneSpace>, region: RegionCoords ) -> MustBoxFuture<'_, Result<Vec<RoughSized<Arc<KitsuneOpHash>>>, Box<dyn Error + Send + Sync>>>

Get all op hashes within a region

fn record_metrics( &self, space: Arc<KitsuneSpace>, records: Vec<MetricRecord> ) -> MustBoxFuture<'_, Result<(), Box<dyn Error + Send + Sync>>>

Record a set of metric records.

fn get_topology( &self, space: Arc<KitsuneSpace> ) -> MustBoxFuture<'_, Result<Topology, Box<dyn Error + Send + Sync>>>

Get the quantum Topology associated with this Space.

fn op_hash( &self, op_data: Arc<KitsuneOpData> ) -> MustBoxFuture<'_, Result<Arc<KitsuneOpHash>, Box<dyn Error + Send + Sync>>>

Hashing function to get an op_hash from op_data.

fn check_op_data( &self, space: Arc<KitsuneSpace>, op_hash_list: Vec<Arc<KitsuneOpHash>>, context: Option<FetchContext> ) -> MustBoxFuture<'_, Result<Vec<bool>, Box<dyn Error + Send + Sync>>>

Check which hashes we have data for.

fn lair_tag(&self) -> Option<Arc<str>>

Get the lair “tag” identifying the id seed to use for crypto signing. (this is currently only used in tx5/WebRTC if that feature is enabled.)

fn lair_client(&self) -> Option<LairClient>

Get the lair client to use as the backend keystore. (this is currently only used in tx5/WebRTC if that feature is enabled.)