Struct SchedulerHost 

pub struct SchedulerHost { /* private fields */ }

Host-side scheduler driver.

One per Uni instance. Constructed during Uni::build; the constructor spawns the driving loop onto the ambient tokio runtime and tracks the join handle through the supplied ShutdownHandle.

Implementations

impl SchedulerHost

pub fn spawn( registry: Arc<PluginRegistry>, persistence: Arc<dyn SchedulerPersistence>, shutdown: &ShutdownHandle, tick_interval: Duration, ) -> Arc<Self>

Construct a scheduler host wired to the supplied PluginRegistry and ShutdownHandle, spawning the driving loop on the ambient tokio runtime.

Reloads previously-persisted jobs via SchedulerPersistence::load_all and registers them with the primitive. Re-queues any orphaned Running runs via Scheduler::requeue_orphaned_runs.

Panics

Does not panic itself, but the spawned driver task panics if no tokio runtime is active. Callers must invoke this from inside a tokio context (which is the case during Uni::build).

pub fn spawn_with_job_host( registry: Arc<PluginRegistry>, persistence: Arc<dyn SchedulerPersistence>, shutdown: &ShutdownHandle, tick_interval: Duration, job_host: Option<Arc<SchedulerJobHost>>, ) -> Arc<Self>

Construct a scheduler host with an attached SchedulerJobHost (built by Uni::build and threaded into every dispatched JobContext).

pub fn job_host(&self) -> Option<&Arc<SchedulerJobHost>>

Borrow the attached SchedulerJobHost (if any).

pub fn circuit_breaker(&self) -> &Arc<CircuitBreaker>

Borrow the host’s circuit breaker. Exposed for tests + the eventual uni.system.circuit_breaker.* introspection procedures.

pub fn scheduler(&self) -> &Arc<Scheduler>

Borrow the underlying primitive scheduler.

pub fn persistence(&self) -> &Arc<dyn SchedulerPersistence>

Borrow the persistence backend.

Trait Implementations

impl Debug for SchedulerHost

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

Formats the value using the given formatter.

impl SchedulerControl for SchedulerHost

SchedulerControl impl for the host-side SchedulerHost.

Delegates list/add/cancel to the inner Scheduler and overrides submit_cypher to dispatch through the attached SchedulerJobHost’s execute_write_cypher. This is what makes the uni.periodic.submit / uni.periodic.iterate procedures actually run Cypher when invoked.

fn add_scheduled_job(&self, id: QName, schedule: Schedule)

Register a job to fire on schedule.

fn cancel(&self, id: &QName) -> bool

Cancel a job by id. Returns true if it existed.

fn list(&self) -> Vec<SchedulerJobRecord>

Snapshot of every known job.

fn submit_cypher(&self, cypher: &str) -> Result<(), FnError>

Submit an inline write-mode Cypher body for synchronous execution. The default impl returns an error so simple scheduler primitives (without a host) can still satisfy the trait shape; the uni-db::scheduler::SchedulerHost override dispatches through its crate::traits::background::JobHost.

fn flush_checkpoint(&self) -> Result<(), FnError>

Drive the persistence backend to flush its checkpoint buffer.