etl_reliability_harness

Deterministic ETL reliability and SLO harness for M33.

Types

BudgetReport

Full M33 budget report.

pub type BudgetReport {
  BudgetReport(
    observations: List(slo.Observation),
    results: List(slo.BudgetResult),
    failed_budgets: Int,
  )
}

Constructors

BudgetReport(
  observations: List(slo.Observation),
  results: List(slo.BudgetResult),
  failed_budgets: Int,
)

Report

Full M33 reliability report.

pub type Report {
  Report(
    outcomes: List(ScenarioOutcome),
    failed_scenarios: Int,
    nondeterministic_failures: Int,
  )
}

Constructors

Report(
  outcomes: List(ScenarioOutcome),
  failed_scenarios: Int,
  nondeterministic_failures: Int,
)

Scenario

M33 reliability scenarios.

pub type Scenario {
  ConnectorOutageRecoveryPath
  PoisonMessageReplayPath
  SchemaEvolutionCompatibilityPath
  ReplayIdempotencyPath
  SloBudgetCompliancePath
}

Constructors

```
ConnectorOutageRecoveryPath
```
```
PoisonMessageReplayPath
```
```
SchemaEvolutionCompatibilityPath
```
```
ReplayIdempotencyPath
```
```
SloBudgetCompliancePath
```

ScenarioOutcome

One scenario outcome.

pub type ScenarioOutcome {
  ScenarioOutcome(
    scenario: Scenario,
    passed: Bool,
    deterministic: Bool,
    signature: String,
  )
}

Constructors

ScenarioOutcome(
  scenario: Scenario,
  passed: Bool,
  deterministic: Bool,
  signature: String,
)

Values

budget_failed_budgets

pub fn budget_failed_budgets(report: BudgetReport) -> Int

Budget-report failed count accessor.

budget_observations

pub fn budget_observations(
  report: BudgetReport,
) -> List(slo.Observation)

Budget-report observation accessor.

budget_report_markdown

pub fn budget_report_markdown() -> String

Deterministic markdown budget report for scripts.

budget_report_signature

pub fn budget_report_signature(report: BudgetReport) -> String

Stable budget report signature.

budget_results

pub fn budget_results(
  report: BudgetReport,
) -> List(slo.BudgetResult)

Budget-report results accessor.

budget_snapshot_signature

pub fn budget_snapshot_signature() -> String

Deterministic budget snapshot signature for drift gates.

budget_snapshot_version

pub const budget_snapshot_version: Int

deterministic

pub fn deterministic(outcome: ScenarioOutcome) -> Bool

Scenario determinism accessor.

failed_scenarios

pub fn failed_scenarios(report: Report) -> Int

Failed scenario count.

nondeterministic_failures

pub fn nondeterministic_failures(report: Report) -> Int

Nondeterministic failure count.

outcomes

pub fn outcomes(report: Report) -> List(ScenarioOutcome)

Report outcomes.

pass_fail_label

pub fn pass_fail_label(outcome: ScenarioOutcome) -> String

Stable pass/fail label.

report_signature

pub fn report_signature(report: Report) -> String

Stable report signature.

run_budget_report

pub fn run_budget_report() -> BudgetReport

Run default M33 budget evaluation report.

run_matrix

pub fn run_matrix() -> Report

Run all M33 reliability scenarios.

run_scenario

pub fn run_scenario(scenario: Scenario) -> ScenarioOutcome

Run one scenario twice and require deterministic parity.

scenario

pub fn scenario(outcome: ScenarioOutcome) -> Scenario

Scenario accessor.

scenario_label

pub fn scenario_label(scenario: Scenario) -> String

Scenario label.

signature

pub fn signature(outcome: ScenarioOutcome) -> String

Scenario signature accessor.

snapshot_report_markdown

pub fn snapshot_report_markdown() -> String

Deterministic markdown report for fixture scripts.

snapshot_signature

pub fn snapshot_signature() -> String

Deterministic snapshot signature for fixture drift gates.

snapshot_version

pub const snapshot_version: Int