lightspeed/ops/connector_harness
Deterministic connector/orchestration conformance harness for M32.
Types
Full M32 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, )
M32 conformance scenarios.
pub type Scenario {
ConnectorSuccessPath
ConnectorFailurePath
BackpressureBoundedQueuePath
OperatorWorkflowPath
}
Constructors
-
ConnectorSuccessPath -
ConnectorFailurePath -
BackpressureBoundedQueuePath -
OperatorWorkflowPath
Values
pub fn nondeterministic_failures(report: Report) -> Int
Nondeterministic failure count.
pub fn run_scenario(scenario: Scenario) -> ScenarioOutcome
Run one scenario twice and require deterministic parity.
pub fn snapshot_report_markdown() -> String
Deterministic markdown report for fixture scripts.
pub fn snapshot_signature() -> String
Deterministic snapshot signature for fixture drift gates.
pub const snapshot_version: Int