Directories
¶
| Path | Synopsis |
|---|---|
|
dispatch
|
|
|
k8s
Package k8s is the Kubernetes dispatch backend: it turns run.requested facts into worker Jobs.
|
Package k8s is the Kubernetes dispatch backend: it turns run.requested facts into worker Jobs. |
|
Package engine is the in-process dispatch backend: it reacts to a run.requested fact and executes the run inside the calling process.
|
Package engine is the in-process dispatch backend: it reacts to a run.requested fact and executes the run inside the calling process. |
|
Package notifier delivers pipeline notifications from ingestion events.
|
Package notifier delivers pipeline notifications from ingestion events. |
|
Package orchestrator owns run intake and lifecycle.
|
Package orchestrator owns run intake and lifecycle. |
|
Package reaper is the zombie-run janitor: on each tick it finds runs stuck in Requested or Running with no write in the staleness window — a worker that never got admitted, a lost pod, an OOM-killed worker, a crashed engine — and emits run.failed so the tracker folds them terminal.
|
Package reaper is the zombie-run janitor: on each tick it finds runs stuck in Requested or Running with no write in the staleness window — a worker that never got admitted, a lost pod, an OOM-killed worker, a crashed engine — and emits run.failed so the tracker folds them terminal. |
|
Package scheduler is the cron firing module: on each tick it claims due schedules, compiles their pipelines into runs, and submits them.
|
Package scheduler is the cron firing module: on each tick it claims due schedules, compiles their pipelines into runs, and submits them. |
|
Package stream is the client-facing read side of the plane.
|
Package stream is the client-facing read side of the plane. |
|
Package streamsupervisor reconciles durable activations independently of bus delivery.
|
Package streamsupervisor reconciles durable activations independently of bus delivery. |
|
Package tracker folds bus facts into DataStore run/resource/checkpoint state.
|
Package tracker folds bus facts into DataStore run/resource/checkpoint state. |
Click to show internal directories.
Click to hide internal directories.