-module(lightspeed@ops@large_data_harness).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/lightspeed/ops/large_data_harness.gleam").
-export([benchmark_signature/1, budget_version_label/0, budget_failures/1, evaluate_budget/2, default_budget/0, run_heavy_benchmarks/0, run_scenario/1, run_matrix/0, scenario_label/1, pass_fail_label/1, signature/1, deterministic/1, scenario/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, benchmark/0, budget/0, budget_result/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 large-data and async-runtime expansion harness for M28.\n").
-type scenario() :: large_list_windowed_incremental |
large_grid_windowed_incremental |
large_chart_windowed_incremental |
async_backpressure_recovery |
heavy_budget_enforcement.
-type scenario_outcome() :: {scenario_outcome,
scenario(),
boolean(),
boolean(),
binary()}.
-type report() :: {report, list(scenario_outcome()), integer(), integer()}.
-type benchmark() :: {benchmark,
binary(),
integer(),
integer(),
integer(),
integer(),
integer(),
integer(),
integer()}.
-type budget() :: {budget,
binary(),
integer(),
integer(),
integer(),
integer(),
integer(),
integer()}.
-type budget_result() :: {budget_result, binary(), boolean(), binary()}.
-file("src/lightspeed/ops/large_data_harness.gleam", 708).
-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/large_data_harness.gleam", 697).
-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/large_data_harness.gleam", 653).
-spec pass_fail_label_from_bool(boolean()) -> binary().
pass_fail_label_from_bool(Value) ->
case Value of
true ->
<<"pass"/utf8>>;
false ->
<<"fail"/utf8>>
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 645).
-spec budget_result_signature(budget_result()) -> binary().
budget_result_signature(Result) ->
<<<<<<<<(erlang:element(2, Result))/binary, ":"/utf8>>/binary,
(pass_fail_label_from_bool(erlang:element(3, Result)))/binary>>/binary,
":"/utf8>>/binary,
(erlang:element(4, Result))/binary>>.
-file("src/lightspeed/ops/large_data_harness.gleam", 740).
-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/large_data_harness.gleam", 243).
?DOC(" Stable benchmark signature.\n").
-spec benchmark_signature(benchmark()) -> binary().
benchmark_signature(Benchmark) ->
<<<<<<<<<<<<<<<<<<<<<<<<<<<<(erlang:element(2, Benchmark))/binary,
":p50="/utf8>>/binary,
(erlang:integer_to_binary(
erlang:element(
3,
Benchmark
)
))/binary>>/binary,
":p95="/utf8>>/binary,
(erlang:integer_to_binary(
erlang:element(4, Benchmark)
))/binary>>/binary,
":avg_payload="/utf8>>/binary,
(erlang:integer_to_binary(
erlang:element(5, Benchmark)
))/binary>>/binary,
":avg_ops="/utf8>>/binary,
(erlang:integer_to_binary(
erlang:element(6, Benchmark)
))/binary>>/binary,
":peak_mem="/utf8>>/binary,
(erlang:integer_to_binary(erlang:element(7, Benchmark)))/binary>>/binary,
":throughput="/utf8>>/binary,
(erlang:integer_to_binary(erlang:element(8, Benchmark)))/binary>>/binary,
":root_churn="/utf8>>/binary,
(erlang:integer_to_binary(erlang:element(9, Benchmark)))/binary>>.
-file("src/lightspeed/ops/large_data_harness.gleam", 176).
?DOC(" M28 benchmark budget profile version.\n").
-spec budget_version_label() -> binary().
budget_version_label() ->
<<"m28.budget.v"/utf8, (erlang:integer_to_binary(1))/binary>>.
-file("src/lightspeed/ops/large_data_harness.gleam", 231).
?DOC(" Number of failing budget checks.\n").
-spec budget_failures(list(budget_result())) -> integer().
budget_failures(Results) ->
case Results of
[] ->
0;
[Result | Rest] ->
case erlang:element(3, Result) of
true ->
budget_failures(Rest);
false ->
1 + budget_failures(Rest)
end
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 733).
-spec bool_label(boolean()) -> binary().
bool_label(Value) ->
case Value of
true ->
<<"true"/utf8>>;
false ->
<<"false"/utf8>>
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 631).
-spec find_benchmark(list(benchmark()), binary()) -> gleam@option:option(benchmark()).
find_benchmark(Benchmarks, Workload) ->
case Benchmarks of
[] ->
none;
[Benchmark | Rest] ->
case erlang:element(2, Benchmark) =:= Workload of
true ->
{some, Benchmark};
false ->
find_benchmark(Rest, Workload)
end
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 581).
-spec evaluate_one_budget(list(benchmark()), budget()) -> budget_result().
evaluate_one_budget(Benchmarks, Budget) ->
case find_benchmark(Benchmarks, erlang:element(2, Budget)) of
none ->
{budget_result,
erlang:element(2, Budget),
false,
<<"missing"/utf8>>};
{some, Benchmark} ->
P95_ok = erlang:element(4, Benchmark) =< erlang:element(3, Budget),
Payload_ok = erlang:element(5, Benchmark) =< erlang:element(
4,
Budget
),
Patch_ok = erlang:element(6, Benchmark) =< erlang:element(5, Budget),
Memory_ok = erlang:element(7, Benchmark) =< erlang:element(
6,
Budget
),
Throughput_ok = erlang:element(8, Benchmark) >= erlang:element(
7,
Budget
),
Churn_ok = erlang:element(9, Benchmark) =< erlang:element(8, Budget),
Passed = ((((P95_ok andalso Payload_ok) andalso Patch_ok) andalso Memory_ok)
andalso Throughput_ok)
andalso Churn_ok,
{budget_result, erlang:element(2, Budget), Passed, case Passed of
true ->
<<"within_budget"/utf8>>;
false ->
<<<<<<<<<<<<<<<<<<<<<<"p95="/utf8,
(bool_label(
P95_ok
))/binary>>/binary,
",payload="/utf8>>/binary,
(bool_label(
Payload_ok
))/binary>>/binary,
",patch="/utf8>>/binary,
(bool_label(Patch_ok))/binary>>/binary,
",memory="/utf8>>/binary,
(bool_label(Memory_ok))/binary>>/binary,
",throughput="/utf8>>/binary,
(bool_label(Throughput_ok))/binary>>/binary,
",churn="/utf8>>/binary,
(bool_label(Churn_ok))/binary>>
end}
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 566).
-spec evaluate_budget_loop(
list(benchmark()),
list(budget()),
list(budget_result())
) -> list(budget_result()).
evaluate_budget_loop(Benchmarks, Budgets, Results_rev) ->
case Budgets of
[] ->
lists:reverse(Results_rev);
[Budget | Rest] ->
evaluate_budget_loop(
Benchmarks,
Rest,
[evaluate_one_budget(Benchmarks, Budget) | Results_rev]
)
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 223).
?DOC(" Evaluate M28 benchmark suite against one budget profile.\n").
-spec evaluate_budget(list(benchmark()), list(budget())) -> list(budget_result()).
evaluate_budget(Benchmarks, Budgets) ->
evaluate_budget_loop(Benchmarks, Budgets, []).
-file("src/lightspeed/ops/large_data_harness.gleam", 181).
?DOC(" Default M28 heavy-workload budgets.\n").
-spec default_budget() -> list(budget()).
default_budget() ->
[{budget, <<"large_grid"/utf8>>, 95, 240, 6, 520, 65, 0},
{budget, <<"large_chart"/utf8>>, 120, 260, 7, 540, 55, 0}].
-file("src/lightspeed/ops/large_data_harness.gleam", 719).
-spec divide_safe(integer(), integer()) -> integer().
divide_safe(Numerator, Denominator) ->
case Denominator =< 0 of
true ->
0;
false ->
case Denominator of
0 -> 0;
Gleam@denominator -> Numerator div Gleam@denominator
end
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 726).
-spec max_int(integer(), integer()) -> integer().
max_int(Left, Right) ->
case Left >= Right of
true ->
Left;
false ->
Right
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 558).
-spec total_payload_bytes(list(lightspeed@diff:patch()), integer()) -> integer().
total_payload_bytes(Patches, Total) ->
case Patches of
[] ->
Total;
[Patch | Rest] ->
total_payload_bytes(
Rest,
Total + string:length(lightspeed@diff:encode(Patch))
)
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 693).
-spec row_payload(binary(), binary()) -> binary().
row_payload(Id, Tag) ->
<<<<<<<<<<<<"<div data-id=\""/utf8, Id/binary>>/binary,
"\" data-tag=\""/utf8>>/binary,
Tag/binary>>/binary,
"\">"/utf8>>/binary,
Id/binary>>/binary,
"</div>"/utf8>>.
-file("src/lightspeed/ops/large_data_harness.gleam", 540).
-spec benchmark_updates(
binary(),
integer(),
integer(),
list(lightspeed@data_plane:update())
) -> list(lightspeed@data_plane:update()).
benchmark_updates(Prefix, Offset, Count, Updates_rev) ->
case Count =< 0 of
true ->
lists:reverse(Updates_rev);
false ->
Id = <<<<Prefix/binary, "-"/utf8>>/binary,
(erlang:integer_to_binary(Offset + Count))/binary>>,
benchmark_updates(
Prefix,
Offset,
Count - 1,
[{upsert,
lightspeed@data_plane:row(
Id,
row_payload(Id, <<"bench"/utf8>>)
)} |
Updates_rev]
)
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 676).
-spec large_rows(binary(), integer(), list(lightspeed@data_plane:row())) -> list(lightspeed@data_plane:row()).
large_rows(Prefix, Total, Rows_rev) ->
case Total =< 0 of
true ->
lists:reverse(Rows_rev);
false ->
Id = <<<<Prefix/binary, "-"/utf8>>/binary,
(erlang:integer_to_binary(Total))/binary>>,
large_rows(
Prefix,
Total - 1,
[lightspeed@data_plane:row(Id, row_payload(Id, <<"seed"/utf8>>)) |
Rows_rev]
)
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 501).
-spec simulate_benchmark(
binary(),
lightspeed@data_plane:dataset(),
integer(),
integer()
) -> benchmark().
simulate_benchmark(Workload, Dataset, Offset, Limit) ->
Target = <<"#"/utf8, Workload/binary>>,
Plane = lightspeed@data_plane:new(
Target,
Dataset,
large_rows(Workload, 700, [])
),
Request = lightspeed@data_plane:request(Offset, Limit),
Updates = benchmark_updates(Workload, Offset, 12, []),
{_, _, Patches} = lightspeed@data_plane:apply_updates(
Plane,
Request,
Updates
),
Total_payload_bytes = total_payload_bytes(Patches, 0),
Patch_ops = erlang:length(Patches),
Avg_payload_bytes = divide_safe(Total_payload_bytes, max_int(1, Patch_ops)),
Avg_patch_ops = divide_safe(Patch_ops, 3),
Root_churn_events = case lightspeed@data_plane:contains_full_root_churn(
Patches
) of
true ->
1;
false ->
0
end,
P50_latency = 12 + divide_safe(Total_payload_bytes, 200),
P95_latency = (P50_latency + 25) + Patch_ops,
Peak_memory = 340 + (Patch_ops * 6),
Throughput = max_int(30, 140 - divide_safe(P95_latency, 2)),
{benchmark,
Workload,
P50_latency,
P95_latency,
Avg_payload_bytes,
Avg_patch_ops,
Peak_memory,
Throughput,
Root_churn_events}.
-file("src/lightspeed/ops/large_data_harness.gleam", 205).
?DOC(" Run deterministic benchmark suite for M28.\n").
-spec run_heavy_benchmarks() -> list(benchmark()).
run_heavy_benchmarks() ->
[simulate_benchmark(<<"large_grid"/utf8>>, {grid_dataset, 8}, 120, 40),
simulate_benchmark(
<<"large_chart"/utf8>>,
{chart_dataset, <<"events"/utf8>>},
160,
50
)].
-file("src/lightspeed/ops/large_data_harness.gleam", 481).
-spec evaluate_heavy_budget() -> {boolean(), binary()}.
evaluate_heavy_budget() ->
Benchmarks = run_heavy_benchmarks(),
Budget = default_budget(),
Results = evaluate_budget(Benchmarks, Budget),
Failures = budget_failures(Results),
Passed = Failures =:= 0,
{Passed,
<<<<<<<<<<<<<<"budget="/utf8, (budget_version_label())/binary>>/binary,
"|benchmarks="/utf8>>/binary,
(join_with(
<<";"/utf8>>,
gleam@list:map(
Benchmarks,
fun benchmark_signature/1
)
))/binary>>/binary,
"|results="/utf8>>/binary,
(join_with(
<<";"/utf8>>,
gleam@list:map(Results, fun budget_result_signature/1)
))/binary>>/binary,
"|failures="/utf8>>/binary,
(erlang:integer_to_binary(Failures))/binary>>}.
-file("src/lightspeed/ops/large_data_harness.gleam", 669).
-spec result_signature(
{ok, nil} | {error, lightspeed@async@backpressure:runtime_error()}
) -> binary().
result_signature(Result) ->
case Result of
{ok, _} ->
<<"ok"/utf8>>;
{error, Error} ->
lightspeed@async@backpressure:error_label(Error)
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 433).
-spec evaluate_async_backpressure() -> {boolean(), binary()}.
evaluate_async_backpressure() ->
Runtime = lightspeed@async@backpressure:new(
lightspeed@async@backpressure:boundary(push_pull, 2, 2, 200)
),
{Runtime@1, B} = lightspeed@async@backpressure:enqueue(
Runtime,
<<"b"/utf8>>
),
{Runtime@2, A} = lightspeed@async@backpressure:enqueue(
Runtime@1,
<<"a"/utf8>>
),
{Runtime@3, Overflow} = lightspeed@async@backpressure:enqueue(
Runtime@2,
<<"overflow"/utf8>>
),
{Runtime@4, Started} = lightspeed@async@backpressure:start_available(
Runtime@3,
10
),
{Runtime@5, Failed} = lightspeed@async@backpressure:fail(
Runtime@4,
<<"a"/utf8>>,
<<"timeout"/utf8>>
),
{Runtime@6, Cancelled} = lightspeed@async@backpressure:cancel(
Runtime@5,
<<"b"/utf8>>,
<<"backpressure"/utf8>>
),
{Runtime@7, Retry_failed} = lightspeed@async@backpressure:retry(
Runtime@6,
<<"a"/utf8>>
),
{Runtime@8, Retry_cancelled} = lightspeed@async@backpressure:retry(
Runtime@7,
<<"b"/utf8>>
),
{Runtime@9, Started_again} = lightspeed@async@backpressure:start_available(
Runtime@8,
30
),
{Runtime@10, Succeeded_a} = lightspeed@async@backpressure:succeed(
Runtime@9,
<<"a"/utf8>>
),
{Runtime@11, Succeeded_b} = lightspeed@async@backpressure:succeed(
Runtime@10,
<<"b"/utf8>>
),
Passed = ((((((((((((((lightspeed@async@backpressure:valid(Runtime@11)
andalso (A =:= {ok, nil}))
andalso (B =:= {ok, nil}))
andalso (Overflow =:= {error, {queue_saturated, <<"overflow"/utf8>>, 2}}))
andalso (Failed =:= {ok, nil}))
andalso (Cancelled =:= {ok, nil}))
andalso (Retry_failed =:= {ok, nil}))
andalso (Retry_cancelled =:= {ok, nil}))
andalso (Succeeded_a =:= {ok, nil}))
andalso (Succeeded_b =:= {ok, nil}))
andalso (erlang:length(Started) =:= 2))
andalso (erlang:length(Started_again) =:= 2))
andalso (lightspeed@async@backpressure:in_flight_count(Runtime@11) =:= 0))
andalso (lightspeed@async@backpressure:queued_count(Runtime@11) =:= 0))
andalso (lightspeed@async@backpressure:state(Runtime@11, <<"a"/utf8>>) =:= {some,
{succeeded, 2}}))
andalso (lightspeed@async@backpressure:state(Runtime@11, <<"b"/utf8>>) =:= {some,
{succeeded, 1}}),
{Passed,
<<<<<<<<<<<<<<"overflow="/utf8, (result_signature(Overflow))/binary>>/binary,
"|started="/utf8>>/binary,
(erlang:integer_to_binary(erlang:length(Started)))/binary>>/binary,
"|started_again="/utf8>>/binary,
(erlang:integer_to_binary(erlang:length(Started_again)))/binary>>/binary,
"|runtime="/utf8>>/binary,
(lightspeed@async@backpressure:signature(Runtime@11))/binary>>}.
-file("src/lightspeed/ops/large_data_harness.gleam", 660).
-spec window_result_signature(
{ok, lightspeed@data_plane:window()} |
{error, lightspeed@data_plane:query_error()}
) -> binary().
window_result_signature(Result) ->
case Result of
{ok, Window} ->
lightspeed@data_plane:window_signature(Window);
{error, Error} ->
<<"error:"/utf8,
(lightspeed@data_plane:query_error_label(Error))/binary>>
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 392).
-spec evaluate_large_chart_window() -> {boolean(), binary()}.
evaluate_large_chart_window() ->
Plane = lightspeed@data_plane:new(
<<"#large-chart"/utf8>>,
{chart_dataset, <<"events"/utf8>>},
large_rows(<<"point"/utf8>>, 360, [])
),
Request = lightspeed@data_plane:request(250, 50),
Updates = [{upsert,
lightspeed@data_plane:row(
<<"point-255"/utf8>>,
row_payload(<<"point-255"/utf8>>, <<"v1"/utf8>>)
)},
{upsert,
lightspeed@data_plane:row(
<<"point-256"/utf8>>,
row_payload(<<"point-256"/utf8>>, <<"v2"/utf8>>)
)},
{delete, <<"point-251"/utf8>>}],
{_, Next_window, Patches} = lightspeed@data_plane:apply_updates(
Plane,
Request,
Updates
),
Passed = case Next_window of
{ok, Window} ->
(((lightspeed@data_plane:valid(Plane) andalso lightspeed@data_plane:steady_state_incremental(
Patches
))
andalso not lightspeed@data_plane:contains_full_root_churn(Patches))
andalso (erlang:element(4, Window) =:= 359))
andalso (erlang:length(erlang:element(5, Window)) =:= 50);
{error, _} ->
false
end,
{Passed,
<<<<<<"patch_ops="/utf8,
(erlang:integer_to_binary(erlang:length(Patches)))/binary>>/binary,
"|next="/utf8>>/binary,
(window_result_signature(Next_window))/binary>>}.
-file("src/lightspeed/ops/large_data_harness.gleam", 356).
-spec evaluate_large_grid_window() -> {boolean(), binary()}.
evaluate_large_grid_window() ->
Plane = lightspeed@data_plane:new(
<<"#large-grid"/utf8>>,
{grid_dataset, 8},
large_rows(<<"grid"/utf8>>, 420, [])
),
Request = lightspeed@data_plane:request(180, 60),
Updates = [{upsert,
lightspeed@data_plane:row(
<<"grid-200"/utf8>>,
row_payload(<<"grid-200"/utf8>>, <<"r1"/utf8>>)
)},
{upsert,
lightspeed@data_plane:row(
<<"grid-219"/utf8>>,
row_payload(<<"grid-219"/utf8>>, <<"r2"/utf8>>)
)},
{delete, <<"grid-181"/utf8>>},
{upsert,
lightspeed@data_plane:row(
<<"grid-451"/utf8>>,
row_payload(<<"grid-451"/utf8>>, <<"new"/utf8>>)
)}],
{_, Next_window, Patches} = lightspeed@data_plane:apply_updates(
Plane,
Request,
Updates
),
Passed = case Next_window of
{ok, Window} ->
(((lightspeed@data_plane:valid(Plane) andalso lightspeed@data_plane:steady_state_incremental(
Patches
))
andalso not lightspeed@data_plane:contains_full_root_churn(Patches))
andalso (erlang:element(4, Window) =:= 420))
andalso (erlang:length(erlang:element(5, Window)) =:= 60);
{error, _} ->
false
end,
{Passed,
<<<<<<"patch_ops="/utf8,
(erlang:integer_to_binary(erlang:length(Patches)))/binary>>/binary,
"|next="/utf8>>/binary,
(window_result_signature(Next_window))/binary>>}.
-file("src/lightspeed/ops/large_data_harness.gleam", 313).
-spec evaluate_large_list_window() -> {boolean(), binary()}.
evaluate_large_list_window() ->
Plane = lightspeed@data_plane:new(
<<"#large-list"/utf8>>,
list_dataset,
large_rows(<<"list"/utf8>>, 300, [])
),
Request = lightspeed@data_plane:request(120, 40),
Updates = [{upsert,
lightspeed@data_plane:row(
<<"list-130"/utf8>>,
<<"<li>list-130:patched</li>"/utf8>>
)},
{delete, <<"list-121"/utf8>>},
{upsert,
lightspeed@data_plane:row(
<<"list-500"/utf8>>,
<<"<li>list-500:new</li>"/utf8>>
)}],
{Next_plane, Next_window, Patches} = lightspeed@data_plane:apply_updates(
Plane,
Request,
Updates
),
Outside_updates = [{upsert,
lightspeed@data_plane:row(
<<"list-2"/utf8>>,
<<"<li>list-2:x</li>"/utf8>>
)}],
{_, _, Steady_patches} = lightspeed@data_plane:apply_updates(
Next_plane,
Request,
Outside_updates
),
Passed = case Next_window of
{ok, Window} ->
((((lightspeed@data_plane:valid(Plane) andalso lightspeed@data_plane:steady_state_incremental(
Patches
))
andalso lightspeed@data_plane:steady_state_incremental(
Steady_patches
))
andalso not lightspeed@data_plane:contains_full_root_churn(Patches))
andalso not lightspeed@data_plane:contains_full_root_churn(
Steady_patches
))
andalso (erlang:element(4, Window) =:= 300);
{error, _} ->
false
end,
{Passed,
<<<<<<<<<<"patch_ops="/utf8,
(erlang:integer_to_binary(erlang:length(Patches)))/binary>>/binary,
"|steady_ops="/utf8>>/binary,
(erlang:integer_to_binary(erlang:length(Steady_patches)))/binary>>/binary,
"|next="/utf8>>/binary,
(window_result_signature(Next_window))/binary>>}.
-file("src/lightspeed/ops/large_data_harness.gleam", 303).
-spec evaluate(scenario()) -> {boolean(), binary()}.
evaluate(Scenario) ->
case Scenario of
large_list_windowed_incremental ->
evaluate_large_list_window();
large_grid_windowed_incremental ->
evaluate_large_grid_window();
large_chart_windowed_incremental ->
evaluate_large_chart_window();
async_backpressure_recovery ->
evaluate_async_backpressure();
heavy_budget_enforcement ->
evaluate_heavy_budget()
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 95).
?DOC(" Run one scenario twice and require deterministic signature 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/large_data_harness.gleam", 76).
?DOC(" Run all M28 scenarios.\n").
-spec run_matrix() -> report().
run_matrix() ->
Outcomes = begin
_pipe = [large_list_windowed_incremental,
large_grid_windowed_incremental,
large_chart_windowed_incremental,
async_backpressure_recovery,
heavy_budget_enforcement],
gleam@list:map(_pipe, fun run_scenario/1)
end,
{report, Outcomes, count_failed(Outcomes), count_nondeterministic(Outcomes)}.
-file("src/lightspeed/ops/large_data_harness.gleam", 111).
?DOC(" Scenario label.\n").
-spec scenario_label(scenario()) -> binary().
scenario_label(Scenario) ->
case Scenario of
large_list_windowed_incremental ->
<<"large_list_windowed_incremental"/utf8>>;
large_grid_windowed_incremental ->
<<"large_grid_windowed_incremental"/utf8>>;
large_chart_windowed_incremental ->
<<"large_chart_windowed_incremental"/utf8>>;
async_backpressure_recovery ->
<<"async_backpressure_recovery"/utf8>>;
heavy_budget_enforcement ->
<<"heavy_budget_enforcement"/utf8>>
end.
-file("src/lightspeed/ops/large_data_harness.gleam", 122).
?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/large_data_harness.gleam", 130).
?DOC(" Scenario signature.\n").
-spec signature(scenario_outcome()) -> binary().
signature(Outcome) ->
erlang:element(5, Outcome).
-file("src/lightspeed/ops/large_data_harness.gleam", 135).
?DOC(" Determinism accessor.\n").
-spec deterministic(scenario_outcome()) -> boolean().
deterministic(Outcome) ->
erlang:element(4, Outcome).
-file("src/lightspeed/ops/large_data_harness.gleam", 140).
?DOC(" Scenario accessor.\n").
-spec scenario(scenario_outcome()) -> scenario().
scenario(Outcome) ->
erlang:element(2, Outcome).
-file("src/lightspeed/ops/large_data_harness.gleam", 145).
?DOC(" Report outcomes.\n").
-spec outcomes(report()) -> list(scenario_outcome()).
outcomes(Report) ->
erlang:element(2, Report).
-file("src/lightspeed/ops/large_data_harness.gleam", 150).
?DOC(" Failed scenario count.\n").
-spec failed_scenarios(report()) -> integer().
failed_scenarios(Report) ->
erlang:element(3, Report).
-file("src/lightspeed/ops/large_data_harness.gleam", 155).
?DOC(" Nondeterministic scenario count.\n").
-spec nondeterministic_failures(report()) -> integer().
nondeterministic_failures(Report) ->
erlang:element(4, Report).
-file("src/lightspeed/ops/large_data_harness.gleam", 160).
?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/large_data_harness.gleam", 262).
?DOC(" Deterministic snapshot signature for fixture drift gates.\n").
-spec snapshot_signature() -> binary().
snapshot_signature() ->
<<<<<<"m28.snapshot.v"/utf8, (erlang:integer_to_binary(1))/binary>>/binary,
"|"/utf8>>/binary,
(report_signature(run_matrix()))/binary>>.
-file("src/lightspeed/ops/large_data_harness.gleam", 270).
?DOC(" Deterministic markdown report for 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,
<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<"# Large Data 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>>.
