pub struct Chronon {
pub store: Arc<dyn SchedulerStore>,
pub scheduler: Arc<Scheduler>,
pub executor: Arc<Executor>,
pub coordinator: CoordinatorService,
pub deployment: DeploymentShape,
/* private fields */
}Expand description
Assembled Chronon runtime: store, scheduler, executor, and deployment loops.
Built via ChrononBuilder. Hosts typically spawn
Chronon::run on a background task and call Chronon::shutdown on exit.
Fields§
§store: Arc<dyn SchedulerStore>Shared persistence for jobs, runs, partitions, and workers.
scheduler: Arc<Scheduler>Tick engine and partition assigner handle.
executor: Arc<Executor>Script registry and async dispatch.
coordinator: CoordinatorServiceJob/run CRUD facade over Self::store.
deployment: DeploymentShapeDeployment shape selected at build time.
Implementations§
Source§impl Chronon
impl Chronon
Sourcepub fn shutdown_handle(&self) -> Arc<Notify>
pub fn shutdown_handle(&self) -> Arc<Notify>
Shared shutdown signal for background Self::run tasks (testkit / host wiring).
Sourcepub async fn run(&mut self) -> Result<()>
pub async fn run(&mut self) -> Result<()>
Run deployment loops until Self::shutdown is called.
Returns an error for DeploymentShape::RemoteClient because no local loops apply.
Sourcepub async fn tick_once(&self) -> Result<TickResult>
pub async fn tick_once(&self) -> Result<TickResult>
Advance the scheduler by one tick (tests and manual stepping).
Sourcepub fn coordinator_service(&self) -> &CoordinatorService
pub fn coordinator_service(&self) -> &CoordinatorService
Job and run CRUD for HTTP handlers and host integration.
Auto Trait Implementations§
impl !RefUnwindSafe for Chronon
impl !UnwindSafe for Chronon
impl Freeze for Chronon
impl Send for Chronon
impl Sync for Chronon
impl Unpin for Chronon
impl UnsafeUnpin for Chronon
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more