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 async fn block(&self, input: Block) -> DatabaseResult<()>

Block some target.

pub async fn unblock(&self, input: Block) -> DatabaseResult<()>

Unblock some target.

pub async fn is_blocked( &self, target_id: BlockTargetId, timestamp: Timestamp ) -> DatabaseResult<bool>

Check if some target is blocked.

pub async fn get_state(&self) -> ConductorResult<ConductorState>

Get the holochain conductor state

pub async fn update_state<F>(&self, f: F) -> ConductorResult<ConductorState>

where F: FnOnce(ConductorState) -> ConductorResult<ConductorState> + 'static + Send,

Update the internal state with a pure function mapping old state to new

pub async fn update_state_prime<F, O>( &self, f: F ) -> ConductorResult<(ConductorState, O)>

where F: FnOnce(ConductorState) -> ConductorResult<(ConductorState, O)> + Send + 'static, O: Send + 'static,

Update the internal state with a pure function mapping old state to new, which may also produce an output value which will be the output of this function

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) -> DatabaseResult<Space>

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

pub fn cache(&self, dna_hash: &DnaHash) -> DatabaseResult<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 ) -> DatabaseResult<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) -> DatabaseResult<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 ) -> DatabaseResult<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 ) -> DatabaseResult<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 ) -> DatabaseResult<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_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>, include_limbo: bool ) -> 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.