-module(lightspeed@ops@overload_harness).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/lightspeed/ops/overload_harness.gleam").
-export([run_scenario/1, run_matrix/0, budget_version_label/0, scenario_label/1, pass_fail_label/1, signature/1, scenario/1, deterministic/1, outcomes/1, failed_scenarios/1, nondeterministic_failures/1, report_signature/1, snapshot_signature/0, snapshot_report_markdown/0]).
-export_type([scenario/0, scenario_outcome/0, report/0]).
-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.
?MODULEDOC(" Deterministic adaptive overload-control and graceful-degradation harness for M50.\n").
-type scenario() :: adaptive_resource_control_boundaries |
graceful_degradation_policy_hooks |
overload_telemetry_audit_determinism |
stress_scenario_and_rollback_drill_certification |
regression_gate_determinism.
-type scenario_outcome() :: {scenario_outcome,
scenario(),
boolean(),
boolean(),
binary()}.
-type report() :: {report, list(scenario_outcome()), integer(), integer()}.
-file("src/lightspeed/ops/overload_harness.gleam", 423).
-spec count_nondeterministic(list(scenario_outcome())) -> integer().
count_nondeterministic(Outcomes) ->
case Outcomes of
[] ->
0;
[Outcome | Rest] ->
case erlang:element(4, Outcome) of
true ->
count_nondeterministic(Rest);
false ->
1 + count_nondeterministic(Rest)
end
end.
-file("src/lightspeed/ops/overload_harness.gleam", 412).
-spec count_failed(list(scenario_outcome())) -> integer().
count_failed(Outcomes) ->
case Outcomes of
[] ->
0;
[Outcome | Rest] ->
case erlang:element(3, Outcome) of
true ->
count_failed(Rest);
false ->
1 + count_failed(Rest)
end
end.
-file("src/lightspeed/ops/overload_harness.gleam", 441).
-spec join_with(binary(), list(binary())) -> binary().
join_with(Separator, Values) ->
case Values of
[] ->
<<""/utf8>>;
[Value] ->
Value;
[Value@1 | Rest] ->
<<<<Value@1/binary, Separator/binary>>/binary,
(join_with(Separator, Rest))/binary>>
end.
-file("src/lightspeed/ops/overload_harness.gleam", 352).
-spec determinism_signature() -> binary().
determinism_signature() ->
Observations = join_with(
<<";"/utf8>>,
gleam@list:map(
lightspeed@ops@overload_control:run_stress_simulation(),
fun lightspeed@ops@overload_control:stress_observation_signature/1
)
),
Runtime = lightspeed@ops@overload_control:new(
lightspeed@ops@overload_control:default_thresholds(),
lightspeed@ops@overload_control:default_hook()
),
Signal = lightspeed@ops@overload_control:signal(
244,
360,
<<"tenant_delta"/utf8>>,
98
),
{After, Status} = lightspeed@ops@overload_control:evaluate(
Runtime,
Signal,
<<"autopilot"/utf8>>,
42
),
<<<<<<<<<<"status="/utf8,
(lightspeed@ops@overload_control:status_label(Status))/binary>>/binary,
"|runtime="/utf8>>/binary,
(lightspeed@ops@overload_control:signature(After))/binary>>/binary,
"|observations="/utf8>>/binary,
Observations/binary>>.
-file("src/lightspeed/ops/overload_harness.gleam", 344).
-spec evaluate_regression_gate_determinism() -> {boolean(), binary()}.
evaluate_regression_gate_determinism() ->
First = determinism_signature(),
Second = determinism_signature(),
Passed = (First =:= Second) andalso (First /= <<""/utf8>>),
{Passed, First}.
-file("src/lightspeed/ops/overload_harness.gleam", 388).
-spec all_observations_rolled_back(
list(lightspeed@ops@overload_control:stress_observation())
) -> boolean().
all_observations_rolled_back(Observations) ->
case Observations of
[] ->
true;
[Observation | Rest] ->
(erlang:element(7, Observation) >= erlang:element(6, Observation))
andalso all_observations_rolled_back(Rest)
end.
-file("src/lightspeed/ops/overload_harness.gleam", 378).
-spec all_observations_bounded(
list(lightspeed@ops@overload_control:stress_observation())
) -> boolean().
all_observations_bounded(Observations) ->
case Observations of
[] ->
true;
[Observation | Rest] ->
erlang:element(8, Observation) andalso all_observations_bounded(
Rest
)
end.
-file("src/lightspeed/ops/overload_harness.gleam", 316).
-spec evaluate_stress_scenario_and_rollback_drill_certification() -> {boolean(),
binary()}.
evaluate_stress_scenario_and_rollback_drill_certification() ->
Observations = lightspeed@ops@overload_control:run_stress_simulation(),
Budgets = lightspeed@ops@overload_control:default_stress_budgets(),
Results = lightspeed@ops@overload_control:evaluate_stress_budgets(
Observations,
Budgets
),
Failures = lightspeed@ops@overload_control:budget_failures(Results),
Passed = (((erlang:length(Observations) =:= 4) andalso (Failures =:= 0))
andalso all_observations_bounded(Observations))
andalso all_observations_rolled_back(Observations),
Signature = <<<<<<"observations="/utf8,
(join_with(
<<";"/utf8>>,
gleam@list:map(
Observations,
fun lightspeed@ops@overload_control:stress_observation_signature/1
)
))/binary>>/binary,
"|budget_results="/utf8>>/binary,
(join_with(
<<";"/utf8>>,
gleam@list:map(
Results,
fun lightspeed@ops@overload_control:budget_result_signature/1
)
))/binary>>,
{Passed, Signature}.
-file("src/lightspeed/ops/overload_harness.gleam", 399).
-spec has_metric(list(lightspeed@ops@telemetry:metric()), binary()) -> boolean().
has_metric(Metrics, Expected_name) ->
case Metrics of
[] ->
false;
[Metric | Rest] ->
case Metric of
{counter, Name, _, _} ->
(Name =:= Expected_name) orelse has_metric(
Rest,
Expected_name
);
{gauge, Name@1, _, _} ->
(Name@1 =:= Expected_name) orelse has_metric(
Rest,
Expected_name
)
end
end.
-file("src/lightspeed/ops/overload_harness.gleam", 277).
-spec evaluate_overload_telemetry_audit_determinism() -> {boolean(), binary()}.
evaluate_overload_telemetry_audit_determinism() ->
Runtime = lightspeed@ops@overload_control:new(
lightspeed@ops@overload_control:default_thresholds(),
lightspeed@ops@overload_control:default_hook()
),
Warning_signal = lightspeed@ops@overload_control:signal(
128,
182,
<<""/utf8>>,
74
),
Critical_signal = lightspeed@ops@overload_control:signal(
238,
346,
<<"tenant_gamma"/utf8>>,
97
),
{After_warning, _} = lightspeed@ops@overload_control:evaluate(
Runtime,
Warning_signal,
<<"autopilot"/utf8>>,
800
),
{After_critical, _} = lightspeed@ops@overload_control:evaluate(
After_warning,
Critical_signal,
<<"autopilot"/utf8>>,
820
),
Rolled_back = lightspeed@ops@overload_control:run_rollback_drill(
After_critical,
<<"autopilot"/utf8>>,
900,
critical
),
Audits = lightspeed@ops@overload_control:audit_entries(Rolled_back),
Metrics = lightspeed@ops@overload_control:telemetry_metrics(Rolled_back),
Metric_lines = gleam@list:map(
Metrics,
fun lightspeed@ops@telemetry:metric_line/1
),
Passed = ((((Audits /= []) andalso (erlang:length(Audits) =:= erlang:length(
Metrics
)))
andalso has_metric(Metrics, <<"lightspeed.overload.mitigation_total"/utf8>>))
andalso (lightspeed@ops@overload_control:active_mitigations(Rolled_back) =:= []))
andalso lightspeed@ops@overload_control:active_mitigations_reversible(
Rolled_back
),
Signature = <<<<<<<<<<"audit_count="/utf8,
(erlang:integer_to_binary(erlang:length(Audits)))/binary>>/binary,
"|metric_count="/utf8>>/binary,
(erlang:integer_to_binary(erlang:length(Metrics)))/binary>>/binary,
"|metrics="/utf8>>/binary,
(join_with(<<";"/utf8>>, Metric_lines))/binary>>,
{Passed, Signature}.
-file("src/lightspeed/ops/overload_harness.gleam", 434).
-spec bool_label(boolean()) -> binary().
bool_label(Value) ->
case Value of
true ->
<<"true"/utf8>>;
false ->
<<"false"/utf8>>
end.
-file("src/lightspeed/ops/overload_harness.gleam", 237).
-spec evaluate_graceful_degradation_policy_hooks() -> {boolean(), binary()}.
evaluate_graceful_degradation_policy_hooks() ->
Runtime = lightspeed@ops@overload_control:new(
lightspeed@ops@overload_control:default_thresholds(),
lightspeed@ops@overload_control:restrictive_hook()
),
Critical_signal = lightspeed@ops@overload_control:signal(
242,
350,
<<"tenant_beta"/utf8>>,
98
),
{After_critical, Status} = lightspeed@ops@overload_control:evaluate(
Runtime,
Critical_signal,
<<"autopilot"/utf8>>,
500
),
Audits = lightspeed@ops@overload_control:audit_entries(After_critical),
Active = lightspeed@ops@overload_control:active_mitigations(After_critical),
Blocked_by_hook = gleam@list:any(
Audits,
fun(Entry) ->
_pipe = lightspeed@ops@overload_control:audit_decision(Entry),
_pipe@1 = lightspeed@ops@overload_control:decision_label(_pipe),
gleam_stdlib:string_starts_with(
_pipe@1,
<<"blocked_by_hook:"/utf8>>
)
end
),
Read_only_active = gleam@list:any(
Active,
fun(Mitigation) ->
lightspeed@ops@overload_control:mitigation_label(Mitigation) =:= <<"enter_read_only_mode"/utf8>>
end
),
Passed = ((((Status =:= critical) andalso Blocked_by_hook) andalso not Read_only_active)
andalso lightspeed@ops@overload_control:policy_compliant(After_critical))
andalso lightspeed@ops@overload_control:valid(After_critical),
Signature = <<<<<<<<<<<<<<"status="/utf8,
(lightspeed@ops@overload_control:status_label(
Status
))/binary>>/binary,
"|blocked_by_hook="/utf8>>/binary,
(bool_label(Blocked_by_hook))/binary>>/binary,
"|read_only_active="/utf8>>/binary,
(bool_label(Read_only_active))/binary>>/binary,
"|audits="/utf8>>/binary,
(join_with(
<<";"/utf8>>,
gleam@list:map(
Audits,
fun lightspeed@ops@overload_control:audit_label/1
)
))/binary>>,
{Passed, Signature}.
-file("src/lightspeed/ops/overload_harness.gleam", 203).
-spec evaluate_adaptive_resource_control_boundaries() -> {boolean(), binary()}.
evaluate_adaptive_resource_control_boundaries() ->
Runtime = lightspeed@ops@overload_control:new(
lightspeed@ops@overload_control:default_thresholds(),
lightspeed@ops@overload_control:default_hook()
),
Warning_signal = lightspeed@ops@overload_control:signal(
132,
188,
<<""/utf8>>,
72
),
Critical_signal = lightspeed@ops@overload_control:signal(
246,
364,
<<"tenant_alpha"/utf8>>,
99
),
{After_warning, Warning_status} = lightspeed@ops@overload_control:evaluate(
Runtime,
Warning_signal,
<<"autopilot"/utf8>>,
100
),
{After_critical, Critical_status} = lightspeed@ops@overload_control:evaluate(
After_warning,
Critical_signal,
<<"autopilot"/utf8>>,
120
),
Active_labels = begin
_pipe = lightspeed@ops@overload_control:active_mitigations(
After_critical
),
gleam@list:map(
_pipe,
fun lightspeed@ops@overload_control:mitigation_label/1
)
end,
Passed = ((((Warning_status =:= warning) andalso (Critical_status =:= critical))
andalso (erlang:length(Active_labels) =:= 4))
andalso lightspeed@ops@overload_control:policy_compliant(After_critical))
andalso lightspeed@ops@overload_control:valid(After_critical),
Signature = <<<<<<<<<<<<<<"statuses="/utf8,
(lightspeed@ops@overload_control:status_label(
Warning_status
))/binary>>/binary,
"->"/utf8>>/binary,
(lightspeed@ops@overload_control:status_label(
Critical_status
))/binary>>/binary,
"|active="/utf8>>/binary,
(join_with(<<","/utf8>>, Active_labels))/binary>>/binary,
"|runtime="/utf8>>/binary,
(lightspeed@ops@overload_control:signature(After_critical))/binary>>,
{Passed, Signature}.
-file("src/lightspeed/ops/overload_harness.gleam", 189).
-spec evaluate(scenario()) -> {boolean(), binary()}.
evaluate(Scenario) ->
case Scenario of
adaptive_resource_control_boundaries ->
evaluate_adaptive_resource_control_boundaries();
graceful_degradation_policy_hooks ->
evaluate_graceful_degradation_policy_hooks();
overload_telemetry_audit_determinism ->
evaluate_overload_telemetry_audit_determinism();
stress_scenario_and_rollback_drill_certification ->
evaluate_stress_scenario_and_rollback_drill_certification();
regression_gate_determinism ->
evaluate_regression_gate_determinism()
end.
-file("src/lightspeed/ops/overload_harness.gleam", 61).
?DOC(" Run one M50 scenario twice and require deterministic parity.\n").
-spec run_scenario(scenario()) -> scenario_outcome().
run_scenario(Scenario) ->
{First_passed, First_signature} = evaluate(Scenario),
{Second_passed, Second_signature} = evaluate(Scenario),
Deterministic = (First_passed =:= Second_passed) andalso (First_signature
=:= Second_signature),
Passed = (First_passed andalso Second_passed) andalso Deterministic,
{scenario_outcome, Scenario, Passed, Deterministic, First_signature}.
-file("src/lightspeed/ops/overload_harness.gleam", 42).
?DOC(" Run all M50 scenarios.\n").
-spec run_matrix() -> report().
run_matrix() ->
Outcomes = begin
_pipe = [adaptive_resource_control_boundaries,
graceful_degradation_policy_hooks,
overload_telemetry_audit_determinism,
stress_scenario_and_rollback_drill_certification,
regression_gate_determinism],
gleam@list:map(_pipe, fun run_scenario/1)
end,
{report, Outcomes, count_failed(Outcomes), count_nondeterministic(Outcomes)}.
-file("src/lightspeed/ops/overload_harness.gleam", 77).
?DOC(" M50 budget profile version label.\n").
-spec budget_version_label() -> binary().
budget_version_label() ->
<<"m50.budget.v"/utf8, (erlang:integer_to_binary(1))/binary>>.
-file("src/lightspeed/ops/overload_harness.gleam", 82).
?DOC(" Scenario label.\n").
-spec scenario_label(scenario()) -> binary().
scenario_label(Scenario) ->
case Scenario of
adaptive_resource_control_boundaries ->
<<"adaptive_resource_control_boundaries"/utf8>>;
graceful_degradation_policy_hooks ->
<<"graceful_degradation_policy_hooks"/utf8>>;
overload_telemetry_audit_determinism ->
<<"overload_telemetry_audit_determinism"/utf8>>;
stress_scenario_and_rollback_drill_certification ->
<<"stress_scenario_and_rollback_drill_certification"/utf8>>;
regression_gate_determinism ->
<<"regression_gate_determinism"/utf8>>
end.
-file("src/lightspeed/ops/overload_harness.gleam", 94).
?DOC(" Stable pass/fail label.\n").
-spec pass_fail_label(scenario_outcome()) -> binary().
pass_fail_label(Outcome) ->
case erlang:element(3, Outcome) of
true ->
<<"pass"/utf8>>;
false ->
<<"fail"/utf8>>
end.
-file("src/lightspeed/ops/overload_harness.gleam", 102).
?DOC(" Scenario signature accessor.\n").
-spec signature(scenario_outcome()) -> binary().
signature(Outcome) ->
erlang:element(5, Outcome).
-file("src/lightspeed/ops/overload_harness.gleam", 107).
?DOC(" Scenario accessor.\n").
-spec scenario(scenario_outcome()) -> scenario().
scenario(Outcome) ->
erlang:element(2, Outcome).
-file("src/lightspeed/ops/overload_harness.gleam", 112).
?DOC(" Determinism accessor.\n").
-spec deterministic(scenario_outcome()) -> boolean().
deterministic(Outcome) ->
erlang:element(4, Outcome).
-file("src/lightspeed/ops/overload_harness.gleam", 117).
?DOC(" Report outcomes accessor.\n").
-spec outcomes(report()) -> list(scenario_outcome()).
outcomes(Report) ->
erlang:element(2, Report).
-file("src/lightspeed/ops/overload_harness.gleam", 122).
?DOC(" Failed scenario count.\n").
-spec failed_scenarios(report()) -> integer().
failed_scenarios(Report) ->
erlang:element(3, Report).
-file("src/lightspeed/ops/overload_harness.gleam", 127).
?DOC(" Nondeterministic scenario count.\n").
-spec nondeterministic_failures(report()) -> integer().
nondeterministic_failures(Report) ->
erlang:element(4, Report).
-file("src/lightspeed/ops/overload_harness.gleam", 132).
?DOC(" Stable report signature.\n").
-spec report_signature(report()) -> binary().
report_signature(Report) ->
Entries = gleam@list:map(
erlang:element(2, Report),
fun(Outcome) ->
<<<<<<<<<<<<(scenario_label(erlang:element(2, Outcome)))/binary,
"="/utf8>>/binary,
(pass_fail_label(Outcome))/binary>>/binary,
":deterministic="/utf8>>/binary,
(bool_label(erlang:element(4, Outcome)))/binary>>/binary,
":"/utf8>>/binary,
(erlang:element(5, Outcome))/binary>>
end
),
join_with(<<";"/utf8>>, Entries).
-file("src/lightspeed/ops/overload_harness.gleam", 148).
?DOC(" Deterministic snapshot signature for M50 fixture drift gates.\n").
-spec snapshot_signature() -> binary().
snapshot_signature() ->
<<<<<<"m50.snapshot.v"/utf8, (erlang:integer_to_binary(1))/binary>>/binary,
"|"/utf8>>/binary,
(report_signature(run_matrix()))/binary>>.
-file("src/lightspeed/ops/overload_harness.gleam", 156).
?DOC(" Deterministic markdown report for M50 fixture scripts.\n").
-spec snapshot_report_markdown() -> binary().
snapshot_report_markdown() ->
Report = run_matrix(),
Failed = failed_scenarios(Report),
Nondeterministic = nondeterministic_failures(Report),
Status = case (Failed =:= 0) andalso (Nondeterministic =:= 0) of
true ->
<<"OK"/utf8>>;
false ->
<<"FAIL"/utf8>>
end,
<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<"# Overload Fixture Report\n\n"/utf8,
"snapshot_version: "/utf8>>/binary,
(erlang:integer_to_binary(
1
))/binary>>/binary,
"\n"/utf8>>/binary,
"budget_version: "/utf8>>/binary,
(budget_version_label(
))/binary>>/binary,
"\n"/utf8>>/binary,
"status: "/utf8>>/binary,
Status/binary>>/binary,
"\n"/utf8>>/binary,
"failed_scenarios: "/utf8>>/binary,
(erlang:integer_to_binary(
Failed
))/binary>>/binary,
"\n"/utf8>>/binary,
"nondeterministic_failures: "/utf8>>/binary,
(erlang:integer_to_binary(Nondeterministic))/binary>>/binary,
"\n\n"/utf8>>/binary,
"snapshot_signature: "/utf8>>/binary,
(snapshot_signature())/binary>>/binary,
"\n\n"/utf8>>/binary,
"report_signature: "/utf8>>/binary,
(report_signature(Report))/binary>>/binary,
"\n"/utf8>>.
