Struct DaemonState 

pub struct DaemonState {
    pub config: DaemonConfig,
    pub audit: Arc<dyn AuditStore>,
    pub policy: PolicyTable,
    pub host_distro: Option<DistroId>,
    pub forwarder: Option<AuditForwarder>,
    pub running_high_risk_reboot: Arc<Mutex<Option<String>>>,
}

Fields

config: DaemonConfig

audit: Arc<dyn AuditStore>

Polymorphic audit store. Concrete impls: SqliteStore (default) and PostgresStore (selected via [storage] backend = "postgres"). Both implement AuditStore async trait.

policy: PolicyTable

host_distro: Option<DistroId>

Strict host identity used to enforce the documented support matrix at preview and execution boundaries.

forwarder: Option<AuditForwarder>

Optional external audit-log forwarder. None when no [audit.forward] sink is configured; events recorded by the dispatcher are then only written to the local hash-chained store.

running_high_risk_reboot: Arc<Mutex<Option<String>>>

Coarse concurrency guard for High-risk reboot-required actions (ME4).

Holds the request_hash of any currently executing action whose ActionSpec has risk_level == High && reboot_required == true (e.g. UbuntuReleaseUpgrade, AddLayeredPackage, RebaseSystem). None when no such action is in flight.

The dispatcher checks this slot before claiming any mutating action. If the slot is occupied the new request is rejected with a ConflictResponse rather than racing the in-flight upgrade and causing dpkg/rpm-ostree lock contention.

The slot is Arc<Mutex<…>> so cloned DaemonState values — one per IPC connection — all share the same underlying guard. Mutex::lock is held for at most a few microseconds; this does not become a hot-path bottleneck because read-only actions skip the check entirely.

On daemon crash the in-memory guard is lost. That is correct: the daemon’s SQLite store will show the orphaned Running row; the operator can inspect it via ListJobHistory.

Implementations

impl DaemonState

pub fn open(config: DaemonConfig) -> Result<Self, DaemonStateError>

Open the daemon state with no policy overrides and no forwarding. Suitable for tests and dev runs.

pub fn open_with_policy( config: DaemonConfig, policy: PolicyTable, ) -> Result<Self, DaemonStateError>

Open the daemon state with an explicit policy table and no forwarding.

pub fn open_full( config: DaemonConfig, policy: PolicyTable, forwarder: Option<AuditForwarder>, ) -> Result<Self, DaemonStateError>

Open the daemon state with full configuration. Production callers (main.rs) build the policy table from [policy.risk_overrides] and the forwarder from [audit.forward]. The audit store defaults to SQLite at config.database_path; pass an explicit audit to use Postgres or any other AuditStore impl.

pub fn open_with_audit( config: DaemonConfig, policy: PolicyTable, forwarder: Option<AuditForwarder>, audit: Arc<dyn AuditStore>, ) -> Self

Open the daemon state with an explicit audit store. Used by main.rs when [storage] backend = "postgres" is configured: the Postgres AuditStore is constructed via PostgresStore::connect and passed here as the audit argument.

pub fn bootstrap( config: DaemonConfig, ) -> Result<DaemonRuntime, DaemonStateError>

Trait Implementations

impl Clone for DaemonState

fn clone(&self) -> DaemonState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DaemonState

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

Formats the value using the given formatter.