Struct InnerState 

pub struct InnerState {

    pub data_dir: PathBuf,
    pub db_path: PathBuf,
    pub unsafe_mode: bool,
    pub async_database: Arc<AsyncDatabase>,
    pub logs_dir: PathBuf,
    pub config_runtime: ArcSwap<ConfigRuntimeSnapshot>,
    pub running: Mutex<HashMap<String, RunningTask>>,
    pub agent_health: RwLock<HashMap<String, AgentHealthState>>,
    pub agent_metrics: RwLock<HashMap<String, AgentMetrics>>,
    pub agent_lifecycle: RwLock<HashMap<String, AgentRuntimeState>>,
    pub message_bus: Arc<MessageBus>,
    pub event_sink: RwLock<Arc<dyn EventSink>>,
    pub db_writer: Arc<DbWriteCoordinator>,
    pub session_store: Arc<AsyncSessionStore>,
    pub task_repo: Arc<AsyncSqliteTaskRepository>,
    pub store_manager: StoreManager,
    pub daemon_runtime: DaemonRuntimeState,
    pub worker_notify: Arc<Notify>,
    pub trigger_event_tx: Sender<TriggerEventPayload>,
    pub trigger_engine_handle: Mutex<Option<TriggerEngineHandle>>,
    pub fs_watcher_reload_tx: Mutex<Option<Sender<()>>>,
    pub task_enqueuer: Arc<dyn TaskEnqueuer>,
}

Shared daemon state referenced by services and scheduler code.

Fields

data_dir: PathBuf

Runtime data directory (~/.orchestratord by default).

db_path: PathBuf

SQLite database path.

unsafe_mode: bool

Whether unsafe mode is enabled.

async_database: Arc<AsyncDatabase>

Async database handle.

logs_dir: PathBuf

Directory containing task and command logs.

config_runtime: ArcSwap<ConfigRuntimeSnapshot>

Atomically swappable configuration snapshot.

running: Mutex<HashMap<String, RunningTask>>

Currently running tasks keyed by task ID.

agent_health: RwLock<HashMap<String, AgentHealthState>>

Runtime agent-health map.

agent_metrics: RwLock<HashMap<String, AgentMetrics>>

Runtime agent metrics map.

agent_lifecycle: RwLock<HashMap<String, AgentRuntimeState>>

Runtime agent lifecycle map.

message_bus: Arc<MessageBus>

Collaboration message bus.

event_sink: RwLock<Arc<dyn EventSink>>

Event sink used by synchronous and asynchronous execution paths.

db_writer: Arc<DbWriteCoordinator>

Serialized database write coordinator.

session_store: Arc<AsyncSessionStore>

Interactive session store.

task_repo: Arc<AsyncSqliteTaskRepository>

Async task repository wrapper.

store_manager: StoreManager

Workflow store manager.

daemon_runtime: DaemonRuntimeState

Runtime daemon lifecycle state.

worker_notify: Arc<Notify>

In-process wakeup channel for idle workers.

trigger_event_tx: Sender<TriggerEventPayload>

Broadcast channel for trigger-relevant task events (task_completed / task_failed).

trigger_engine_handle: Mutex<Option<TriggerEngineHandle>>

Handle for notifying the trigger engine of config changes.

fs_watcher_reload_tx: Mutex<Option<Sender<()>>>

Handle for notifying the filesystem watcher of config changes. Set by the daemon; None in CLI-only contexts.

task_enqueuer: Arc<dyn TaskEnqueuer>

Scheduler port for cross-crate task enqueue dispatch.

Wired with the real scheduler implementation by the daemon; defaults to NoopTaskEnqueuer in tests and CLI-only contexts.

Implementations

impl InnerState

pub fn emit_event( &self, task_id: &str, task_item_id: Option<&str>, event_type: &str, payload: Value, )

Emits an event through the currently configured event sink.

When the event is task_completed or task_failed, it is also broadcast on trigger_event_tx so the trigger engine can evaluate event triggers.