Struct DurableProcessWorkerConfig 

pub struct DurableProcessWorkerConfig {
    pub plugin_host: Arc<PluginHost>,
    pub runtime_host: RuntimeHostConfig,
    pub session_policy: SessionPolicy,
    pub session_store_factory: Arc<dyn SessionStoreFactory>,
    pub process_registry: Arc<dyn ProcessRegistry>,
    pub host_event_store: Arc<dyn HostEventStore>,
    pub residency: Residency,
}

Deployment-local configuration for rebuilding durable process executions.

Process rows intentionally carry only portable process input and provenance. Workers provide the host profile, plugins, providers, stores, secrets, and host capabilities for the deployment that owns those rows.

Fields

plugin_host: Arc<PluginHost>

runtime_host: RuntimeHostConfig

session_policy: SessionPolicy

session_store_factory: Arc<dyn SessionStoreFactory>

process_registry: Arc<dyn ProcessRegistry>

host_event_store: Arc<dyn HostEventStore>

residency: Residency

Residency for sessions the worker rebuilds to run a process. Defaults to [Residency::KeepAll]; a host running [Residency::ActivePathOnly] wires it here so the worker’s rebuilt sessions trim to the active path too, instead of silently diverging from the live runtime by keeping the full graph resident.

Implementations

impl DurableProcessWorkerConfig

pub fn new( plugin_host: Arc<PluginHost>, runtime_host: RuntimeHostConfig, session_store_factory: Arc<dyn SessionStoreFactory>, process_registry: Arc<dyn ProcessRegistry>, ) -> Self

pub fn with_host_event_store(self, store: Arc<dyn HostEventStore>) -> Self

pub fn with_session_policy(self, policy: SessionPolicy) -> Self

pub fn with_residency(self, residency: Residency) -> Self

pub fn from_plugin_factories( plugin_factories: impl IntoIterator<Item = Arc<dyn PluginFactory>>, runtime_host: RuntimeHostConfig, session_store_factory: Arc<dyn SessionStoreFactory>, process_registry: Arc<dyn ProcessRegistry>, ) -> Self

pub fn from_plugin_stack( plugin_stack: PluginStack, runtime_host: RuntimeHostConfig, session_store_factory: Arc<dyn SessionStoreFactory>, process_registry: Arc<dyn ProcessRegistry>, ) -> Self

Trait Implementations

impl Clone for DurableProcessWorkerConfig

fn clone(&self) -> DurableProcessWorkerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.