Struct holochain::conductor::space::Spaces

pub struct Spaces { /* private fields */ }

This is the set of all current DnaHash spaces for all cells installed on this conductor.

Implementations

impl Spaces

pub fn new(config: &ConductorConfig) -> ConductorResult<Self>

Create a new empty set of DnaHash spaces.

pub fn get_from_spaces<R, F: FnMut(&Space) -> R>(&self, f: F) -> Vec<R>

Get something from every space

pub fn get_or_create_space(&self, dna_hash: &DnaHash) -> ConductorResult<Space>

Get the space if it exists or create it if it doesn’t.

pub fn cache(&self, dna_hash: &DnaHash) -> ConductorResult<DbWrite<DbKindCache>>

Get the cache database (this will create the space if it doesn’t already exist).

pub fn authored_db(
    &self,
    dna_hash: &DnaHash
) -> ConductorResult<DbWrite<DbKindAuthored>>

Get the authored database (this will create the space if it doesn’t already exist).

pub fn dht_db(&self, dna_hash: &DnaHash) -> ConductorResult<DbWrite<DbKindDht>>

Get the dht database (this will create the space if it doesn’t already exist).

pub fn p2p_agents_db(
    &self,
    dna_hash: &DnaHash
) -> ConductorResult<DbWrite<DbKindP2pAgents>>

Get the peer database (this will create the space if it doesn’t already exist).

pub fn p2p_metrics_db(
    &self,
    dna_hash: &DnaHash
) -> ConductorResult<DbWrite<DbKindP2pMetrics>>

Get the peer database (this will create the space if it doesn’t already exist).

pub fn p2p_batch_sender(
    &self,
    dna_hash: &DnaHash
) -> ConductorResult<Sender<P2pBatch>>

Get the batch sender (this will create the space if it doesn’t already exist).

pub async fn handle_query_op_hashes(
    &self,
    dna_hash: &DnaHash,
    dht_arc_set: DhtArcSet,
    window: TimeWindow,
    max_ops: usize,
    include_limbo: bool
) -> ConductorResult<Option<(Vec<DhtOpHash>, TimeWindowInclusive)>>

the network module is requesting a list of dht op hashes Get the DhtOpHashes and authored timestamps for a given time window.

pub async fn handle_fetch_op_regions(
    &self,
    dna_hash: &DnaHash,
    topology: Topology,
    dht_arc_set: DhtArcSet
) -> ConductorResult<RegionSetLtcs>

The network module needs info about various groupings (“regions”) of ops

Note that this always includes all ops regardless of integration status. This is to avoid the degenerate case of freshly joining a network, and having several new peers gossiping with you at once about the same regions. If we calculate our region hash only by integrated ops, we will experience mismatches for a large number of ops repeatedly until we have integrated those ops. Note that when sending ops we filter out ops in limbo.

pub async fn handle_fetch_op_data(
    &self,
    dna_hash: &DnaHash,
    query: FetchOpDataQuery
) -> ConductorResult<Vec<(DhtOpHash, DhtOp)>>

The network module is requesting the content for dht ops

pub async fn handle_fetch_op_data_by_regions(
    &self,
    dna_hash: &DnaHash,
    regions: Vec<RegionBounds>
) -> ConductorResult<Vec<(DhtOpHash, DhtOp)>>

The network module is requesting the content for dht ops

pub async fn handle_fetch_op_data_by_hashes(
    &self,
    dna_hash: &DnaHash,
    op_hashes: Vec<DhtOpHash>
) -> ConductorResult<Vec<(DhtOpHash, DhtOp)>>

The network module is requesting the content for dht ops

pub async fn handle_publish(
    &self,
    dna_hash: &DnaHash,
    request_validation_receipt: bool,
    countersigning_session: bool,
    ops: Vec<DhtOp>
) -> ConductorResult<()>

we are receiving a “publish” event from the network

pub fn recent_threshold(&self) -> Duration

Get the recent_threshold based on the kitsune network config

Trait Implementations

impl Clone for Spaces

fn clone(&self) -> Spaces

Returns a copy of the value.

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

Performs copy-assignment from source.