Kickside durable leased-job engine and projection scheduler — jobs service/api/persist/workers, effect-intent machinery, and the leased cursor scheduler

BUSL-1.1 2.1k downloads
Updated 3 days ago Repository
kicksidejobsschedulereffectsengine

Run

wippy run kickside/jobs

kickside/jobs

Durable leased-job engine and projection scheduler, extracted from kickside/core.

  • kickside.core.jobs — shared job vocabulary, env-tunable knobs, the component-facing durable job API, and the atomic thread-fact emitter.
  • kickside.core.jobs.persist — claim/lease/lifecycle over kickside_job, the effect-intent and hydration executors, and the side-effect intent recorder.
  • kickside.core.jobs.service — the supervised worker pool that claims and executes jobs.
  • kickside.core.scheduler — the leased cursor scheduler that reclaims expired locks and dispatches due projection cursors, driving the core projection catch-up engine.
  • kickside.core.jobs.migrations — the kickside_job / effect-intent / hydration schema.

Depends on kickside/core for threads, events, projections, execution identity, trace, and shared proc supervision.

Dependency interface

The host must supply target_db; it is injected into both the jobs migration and the module-owned db_config. The worker, APIs, job client, lease logic, and scheduler all resolve that config, so runtime SQL always follows the host's database mapping.