Observability — workers, grains and sagas¶
Generated from the architecture model
This page is rendered from model/**/*.yaml by tools/docs_model during mkdocs build. Edit the YAML, not this page; hand-written design lives on the linked service, platform and plane pages.
Workers¶
| Worker | Service | Trigger | Output events | Retry | Idempotency key | Concurrency |
|---|---|---|---|---|---|---|
| MetricRuleEvaluator | AlertRuleService | schedule */1 * * * * |
AlertFired, AlertResolved | fixed ×2 | ruleId + minute |
4 by TenantId |
| Notifier | AlertRuleService | event AlertRuleService.AlertFired | — | exponential ×5 | alertId + route |
4 by TenantId |
| ProjectionRebuilder | DashboardService | manual on RebuildRunProjection or restore |
RunProjectionUpdated | exponential ×5 | runId + lastEventSequence |
4 by TenantId |
| OverviewAggregator | DashboardService | schedule */5 * * * * |
OperationsDigestProduced | fixed ×3 | tenantId + window + computedAt |
2 by TenantId |
| ProposalGenerator | FeedbackService | schedule 0 6 * * * |
LearningProposalRaised | fixed ×2 | targetAssetId + evidenceHash |
2 by TenantId |
| DatasetSnapshotter | FeedbackService | manual on SnapshotDataset |
DatasetPublished | exponential ×3 | datasetId + version |
2 by TenantId |
| SuiteRunner | QualityScoreService | event AgentRegistryService.AssetReleaseSubmitted | EvaluationStarted, EvaluationCompleted, EvaluationFailed | exponential ×3 | evaluationId + taskId |
2 by TenantId |
| DriftMonitor | QualityScoreService | schedule 0 */6 * * * |
DriftDetected | fixed ×2 | targetReleaseId + window |
2 by TenantId |
| SloEvaluator | SloService | schedule */5 * * * * |
SloBreached, SloRecovered | fixed ×3 | sloId + window |
2 by TenantId |
| HealthCollector | SloService | schedule */1 * * * * |
ServiceHealthChanged | fixed ×2 | hostId + minute |
8 by HostId |
- MetricRuleEvaluator (AlertRuleService): Evaluates metric-threshold rules against the backend on a schedule and fires or resolves instances.
- Notifier (AlertRuleService): Delivers notifications for fired alerts through the Studio and connectors with receipts.
- ProjectionRebuilder (DashboardService): Rebuilds run projections from Run Control's journal and producers' events after a restore or on request.
- OverviewAggregator (DashboardService): Recomputes overview metrics per subject and window from run projections.
- ProposalGenerator (FeedbackService): Clusters feedback, drift and failed evaluations per asset and drafts proposals with evidence and an expected effect (structured profile); never applies anything.
- DatasetSnapshotter (FeedbackService): Builds dataset snapshots from harvested tasks and curated additions and stores them as artifacts.
- SuiteRunner (QualityScoreService): Executes the tasks of a suite as Factory runs under the evaluation project, collects per-task metrics and computes the verdict against thresholds and the baseline.
- DriftMonitor (QualityScoreService): Compares production outcome statistics per release with its evaluated scores and raises drift.
- SloEvaluator (SloService): Evaluates every active objective from projections and metrics, computes burn rates and emits breaches and recoveries.
- HealthCollector (SloService): Collects host health from the HealthChecks aggregator and the hosts' probes and updates the rollup.
Grains (actors)¶
None modelled
No grains are modelled for this item yet.
Sagas¶
None modelled
No sagas are modelled for this item yet.