Struct holochain::core::queue_consumer::QueueConsumerMap

pub struct QueueConsumerMap { /* private fields */ }

Map of running queue consumers workflows per dna space.

Implementations

impl QueueConsumerMap

pub fn new() -> Self

Create a new queue consumer map.

Examples found in repository

src/core/queue_consumer.rs (line 269)

    fn default() -> Self {
        Self::new()
    }

src/conductor/space.rs (line 159)

    pub fn new(config: &ConductorConfig) -> ConductorResult<Self> {
        let root_db_dir = config.environment_path.clone();
        let db_sync_strategy = config.db_sync_strategy;
        let db_sync_level = match db_sync_strategy {
            DbSyncStrategy::Fast => DbSyncLevel::Off,
            DbSyncStrategy::Resilient => DbSyncLevel::Normal,
        };
        let conductor_db =
            DbWrite::open_with_sync_level(root_db_dir.as_ref(), DbKindConductor, db_sync_level)?;
        let wasm_db =
            DbWrite::open_with_sync_level(root_db_dir.as_ref(), DbKindWasm, db_sync_level)?;
        Ok(Spaces {
            map: RwShare::new(HashMap::new()),
            db_dir: Arc::new(root_db_dir),
            db_sync_strategy,
            queue_consumer_map: QueueConsumerMap::new(),
            conductor_db,
            wasm_db,
            network_config: config.network.clone().unwrap_or_default(),
        })
    }

pub fn validation_receipt_trigger(
    &self,
    dna_hash: Arc<DnaHash>
) -> Option<TriggerSender>

Get the validation receipt trigger for this dna hash.

pub fn integration_trigger(
    &self,
    dna_hash: Arc<DnaHash>
) -> Option<TriggerSender>

Get the integration trigger for this dna hash.

Examples found in repository

src/conductor/cell.rs (line 212)

    pub async fn genesis<Ribosome>(
        id: CellId,
        conductor_handle: ConductorHandle,
        authored_db: DbWrite<DbKindAuthored>,
        dht_db: DbWrite<DbKindDht>,
        dht_db_cache: DhtDbQueryCache,
        ribosome: Ribosome,
        membrane_proof: Option<MembraneProof>,
        chc: Option<ChcImpl>,
    ) -> CellResult<()>
    where
        Ribosome: RibosomeT + 'static,
    {
        // get the dna
        let dna_file = conductor_handle
            .get_dna_file(id.dna_hash())
            .ok_or_else(|| DnaError::DnaMissing(id.dna_hash().to_owned()))?;

        let conductor_api = CellConductorApi::new(conductor_handle.clone(), id.clone());

        // run genesis
        let workspace = GenesisWorkspace::new(authored_db, dht_db)
            .map_err(ConductorApiError::from)
            .map_err(Box::new)?;

        // exit early if genesis has already run
        if workspace.has_genesis(id.agent_pubkey().clone()).await? {
            return Ok(());
        }

        let args = GenesisWorkflowArgs::new(
            dna_file,
            id.agent_pubkey().clone(),
            membrane_proof,
            ribosome,
            dht_db_cache,
            chc,
        );

        genesis_workflow(workspace, conductor_api, args)
            .await
            .map_err(ConductorApiError::from)
            .map_err(Box::new)?;

        if let Some(trigger) = conductor_handle
            .get_queue_consumer_workflows()
            .integration_trigger(Arc::new(id.dna_hash().clone()))
        {
            trigger.trigger(&"genesis");
        }
        Ok(())
    }

pub fn sys_validation_trigger(
    &self,
    dna_hash: Arc<DnaHash>
) -> Option<TriggerSender>

Get the sys validation trigger for this dna hash.

pub fn app_validation_trigger(
    &self,
    dna_hash: Arc<DnaHash>
) -> Option<TriggerSender>

Get the app validation trigger for this dna hash.

pub fn countersigning_trigger(
    &self,
    dna_hash: Arc<DnaHash>
) -> Option<TriggerSender>

Get the countersigning trigger for this dna hash.

Trait Implementations

impl Clone for QueueConsumerMap

fn clone(&self) -> QueueConsumerMap

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for QueueConsumerMap

fn default() -> Self

Returns the “default value” for a type.