Directories
¶
| Path | Synopsis |
|---|---|
|
Package compile turns a stored pipeline into per-route run requests.
|
Package compile turns a stored pipeline into per-route run requests. |
|
Package convert maps root types onto the generated API types and back.
|
Package convert maps root types onto the generated API types and back. |
|
Package cron parses standard 5-field cron expressions and computes the next fire time, with no external dependencies.
|
Package cron parses standard 5-field cron expressions and computes the next fire time, with no external dependencies. |
|
modules
|
|
|
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. |
|
engine
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. |
|
notifier
Package notifier delivers pipeline notifications from ingestion events.
|
Package notifier delivers pipeline notifications from ingestion events. |
|
orchestrator
Package orchestrator owns run intake and lifecycle.
|
Package orchestrator owns run intake and lifecycle. |
|
reaper
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. |
|
scheduler
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. |
|
stream
Package stream is the client-facing read side of the plane.
|
Package stream is the client-facing read side of the plane. |
|
streamsupervisor
Package streamsupervisor reconciles durable activations independently of bus delivery.
|
Package streamsupervisor reconciles durable activations independently of bus delivery. |
|
tracker
Package tracker folds bus facts into DataStore run/resource/checkpoint state.
|
Package tracker folds bus facts into DataStore run/resource/checkpoint state. |
|
Package naming normalizes display names into destination identifiers.
|
Package naming normalizes display names into destination identifiers. |
|
Package notifier contains private notification validation and delivery contracts.
|
Package notifier contains private notification validation and delivery contracts. |
|
slack
Package slack delivers notifications to Slack incoming webhooks.
|
Package slack delivers notifications to Slack incoming webhooks. |
|
webhook
Package webhook defines webhook destination configuration and validation.
|
Package webhook defines webhook destination configuration and validation. |
|
Package runs holds the run-intake primitive shared by the control-plane modules.
|
Package runs holds the run-intake primitive shared by the control-plane modules. |
|
Package schedule contains schedule-domain validation and timing calculations.
|
Package schedule contains schedule-domain validation and timing calculations. |
|
Package stream provides shared source and sink lifecycle bookkeeping.
|
Package stream provides shared source and sink lifecycle bookkeeping. |
|
Package streamproof carries process-local pipeline completion evidence.
|
Package streamproof carries process-local pipeline completion evidence. |
|
Package usage samples this process's cgroup v2 CPU and memory accounting.
|
Package usage samples this process's cgroup v2 CPU and memory accounting. |
Click to show internal directories.
Click to hide internal directories.