-module(lightspeed@data_plane_huge).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/lightspeed/data_plane_huge.gleam").
-export([compact_transport_profiles/0, default_transport_profile/0, new/6, million_row_plane/3, request/3, burst_batch/4, compact_transport_valid/1, valid/1, query_window/2, apply_burst_updates/3, steady_state_no_full_root_churn/1, ordering_invariant/1, run_huge_benchmarks/0, default_huge_budgets/0, evaluate_huge_budgets/2, budget_failures/1, dataset_label/1, transport_label/1, query_error_label/1, patch_summary_signature/1, window_signature/1, signature/1, benchmark_signature/1, budget_result_signature/1, target/1, dataset/1, total_rows/1, transport/1, window_sequence/1, window_version/1]).
-export_type([dataset/0, transport_profile/0, plane/0, window_request/0, window/0, burst_batch/0, patch_summary/0, query_error/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(" Data-plane 2.0 contracts for million-row and burst-analytics workloads (M51).\n").

-type dataset() :: million_row_list |
    {million_row_grid, integer()} |
    {burst_analytics, integer()}.

-type transport_profile() :: {transport_profile,
        binary(),
        binary(),
        integer(),
        integer(),
        binary()}.

-opaque plane() :: {plane,
        binary(),
        dataset(),
        integer(),
        integer(),
        binary(),
        transport_profile(),
        integer(),
        integer(),
        integer()}.

-type window_request() :: {window_request, integer(), integer(), integer()}.

-type window() :: {window,
        integer(),
        integer(),
        integer(),
        integer(),
        integer(),
        integer(),
        integer()}.

-type burst_batch() :: {burst_batch, binary(), integer(), integer(), integer()}.

-type patch_summary() :: {patch_summary,
        integer(),
        integer(),
        boolean(),
        binary()}.

-type query_error() :: {invalid_window, integer(), integer()} |
    {sequence_regressed, 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/data_plane_huge.gleam", 111).
?DOC(" Deterministic compact transport profile matrix.\n").
-spec compact_transport_profiles() -> list(transport_profile()).
compact_transport_profiles() ->
    [{transport_profile,
            <<"ws_compact_delta"/utf8>>,
            <<"binary"/utf8>>,
            4096,
            2000,
            <<"delta_keys"/utf8>>},
        {transport_profile,
            <<"sse_compact_json"/utf8>>,
            <<"json"/utf8>>,
            6144,
            1500,
            <<"columnar_json"/utf8>>},
        {transport_profile,
            <<"longpoll_compact_delta"/utf8>>,
            <<"json"/utf8>>,
            3072,
            1200,
            <<"delta_keys"/utf8>>}].

-file("src/lightspeed/data_plane_huge.gleam", 138).
?DOC(" Default transport profile for huge-data workloads.\n").
-spec default_transport_profile() -> transport_profile().
default_transport_profile() ->
    {transport_profile,
        <<"ws_compact_delta"/utf8>>,
        <<"binary"/utf8>>,
        4096,
        2000,
        <<"delta_keys"/utf8>>}.

-file("src/lightspeed/data_plane_huge.gleam", 149).
?DOC(" Build a huge-data plane.\n").
-spec new(
    binary(),
    dataset(),
    integer(),
    integer(),
    binary(),
    transport_profile()
) -> plane().
new(Target, Dataset, Total_rows, Window_limit, Ordering_key, Transport) ->
    {plane,
        Target,
        Dataset,
        Total_rows,
        Window_limit,
        Ordering_key,
        Transport,
        1,
        0,
        0}.

-file("src/lightspeed/data_plane_huge.gleam", 171).
?DOC(" Build the default million-row plane for one dataset profile.\n").
-spec million_row_plane(binary(), dataset(), transport_profile()) -> plane().
million_row_plane(Target, Dataset, Transport) ->
    new(Target, Dataset, 1000000, 2000, <<"row_id"/utf8>>, Transport).

-file("src/lightspeed/data_plane_huge.gleam", 180).
?DOC(" Build one window request.\n").
-spec request(integer(), integer(), integer()) -> window_request().
request(Offset, Limit, Sequence) ->
    {window_request, Offset, Limit, Sequence}.

-file("src/lightspeed/data_plane_huge.gleam", 185).
?DOC(" Build one burst update batch.\n").
-spec burst_batch(binary(), integer(), integer(), integer()) -> burst_batch().
burst_batch(Batch_id, Upserts, Deletes, Max_sequence) ->
    {burst_batch, Batch_id, Upserts, Deletes, Max_sequence}.

-file("src/lightspeed/data_plane_huge.gleam", 213).
?DOC(" Validate one compact transport profile.\n").
-spec compact_transport_valid(transport_profile()) -> boolean().
compact_transport_valid(Profile) ->
    ((((erlang:element(2, Profile) /= <<""/utf8>>) andalso (erlang:element(
        4,
        Profile
    )
    > 0))
    andalso (erlang:element(5, Profile) > 0))
    andalso ((erlang:element(3, Profile) =:= <<"binary"/utf8>>) orelse (erlang:element(
        3,
        Profile
    )
    =:= <<"json"/utf8>>)))
    andalso ((erlang:element(6, Profile) =:= <<"delta_keys"/utf8>>) orelse (erlang:element(
        6,
        Profile
    )
    =:= <<"columnar_json"/utf8>>)).

-file("src/lightspeed/data_plane_huge.gleam", 541).
-spec dataset_valid(dataset()) -> boolean().
dataset_valid(Dataset) ->
    case Dataset of
        million_row_list ->
            true;

        {million_row_grid, Columns} ->
            Columns > 0;

        {burst_analytics, Cubes} ->
            Cubes > 0
    end.

-file("src/lightspeed/data_plane_huge.gleam", 200).
?DOC(" Validate one huge-data plane.\n").
-spec valid(plane()) -> boolean().
valid(Plane) ->
    ((((((((erlang:element(2, Plane) /= <<""/utf8>>) andalso dataset_valid(
        erlang:element(3, Plane)
    ))
    andalso (erlang:element(4, Plane) >= 0))
    andalso (erlang:element(5, Plane) > 0))
    andalso (erlang:element(6, Plane) /= <<""/utf8>>))
    andalso compact_transport_valid(erlang:element(7, Plane)))
    andalso (erlang:element(8, Plane) > 0))
    andalso (erlang:element(9, Plane) >= 0))
    andalso (erlang:element(10, Plane) >= 0).

-file("src/lightspeed/data_plane_huge.gleam", 722).
-spec max_int(integer(), integer()) -> integer().
max_int(Left, Right) ->
    case Left >= Right of
        true ->
            Left;

        false ->
            Right
    end.

-file("src/lightspeed/data_plane_huge.gleam", 549).
-spec build_window(plane(), integer(), integer(), integer()) -> window().
build_window(Plane, Offset, Limit, Sequence) ->
    Clamped_offset = gleam@int:clamp(Offset, 0, erlang:element(4, Plane)),
    Remaining = max_int(0, erlang:element(4, Plane) - Clamped_offset),
    Actual_limit = gleam@int:clamp(Limit, 0, Remaining),
    First_index = case Actual_limit =:= 0 of
        true ->
            0;

        false ->
            Clamped_offset + 1
    end,
    Last_index = case Actual_limit =:= 0 of
        true ->
            0;

        false ->
            Clamped_offset + Actual_limit
    end,
    {window,
        Clamped_offset,
        Limit,
        erlang:element(4, Plane),
        First_index,
        Last_index,
        erlang:element(8, Plane),
        Sequence}.

-file("src/lightspeed/data_plane_huge.gleam", 225).
?DOC(" Query one huge-data window.\n").
-spec query_window(plane(), window_request()) -> {ok, window()} |
    {error, query_error()}.
query_window(Plane, Request) ->
    case ((erlang:element(2, Request) < 0) orelse (erlang:element(3, Request) =< 0))
    orelse (erlang:element(3, Request) > erlang:element(5, Plane)) of
        true ->
            {error,
                {invalid_window,
                    erlang:element(2, Request),
                    erlang:element(3, Request)}};

        false ->
            case erlang:element(4, Request) < erlang:element(10, Plane) of
                true ->
                    {error,
                        {sequence_regressed,
                            erlang:element(10, Plane),
                            erlang:element(4, Request)}};

                false ->
                    {ok,
                        build_window(
                            Plane,
                            erlang:element(2, Request),
                            erlang:element(3, Request),
                            erlang:element(4, Request)
                        )}
            end
    end.

-file("src/lightspeed/data_plane_huge.gleam", 578).
-spec summarize_patch(transport_profile(), integer(), burst_batch()) -> patch_summary().
summarize_patch(Profile, Limit, Batch) ->
    Changed_rows = erlang:element(3, Batch) + erlang:element(4, Batch),
    Patch_ops = gleam@int:clamp(
        (Changed_rows div 30) + 4,
        1,
        max_int(1, (Limit div 30) + 10)
    ),
    Payload_bytes = case erlang:element(6, Profile) of
        <<"columnar_json"/utf8>> ->
            (Patch_ops * 84) + 920;

        _ ->
            (Patch_ops * 72) + 880
    end,
    Full_root_churn = Changed_rows > max_int(1, Limit * 16),
    {patch_summary,
        Patch_ops,
        Payload_bytes,
        Full_root_churn,
        erlang:element(2, Profile)}.

-file("src/lightspeed/data_plane_huge.gleam", 254).
?DOC(" Apply one burst update batch and emit compact patch summary.\n").
-spec apply_burst_updates(plane(), window_request(), burst_batch()) -> {plane(),
    {ok, window()} | {error, query_error()},
    patch_summary()}.
apply_burst_updates(Plane, Request, Batch) ->
    Next_total = max_int(
        0,
        (erlang:element(4, Plane) + erlang:element(3, Batch)) - erlang:element(
            4,
            Batch
        )
    ),
    Next_sequence = max_int(erlang:element(10, Plane), erlang:element(5, Batch)),
    Next_plane = {plane,
        erlang:element(2, Plane),
        erlang:element(3, Plane),
        Next_total,
        erlang:element(5, Plane),
        erlang:element(6, Plane),
        erlang:element(7, Plane),
        erlang:element(8, Plane) + 1,
        erlang:element(9, Plane) + 1,
        Next_sequence},
    Next_request = {window_request,
        erlang:element(2, Request),
        erlang:element(3, Request),
        Next_sequence},
    Next_window = query_window(Next_plane, Next_request),
    Patch = summarize_patch(
        erlang:element(7, Next_plane),
        erlang:element(3, Request),
        Batch
    ),
    {Next_plane, Next_window, Patch}.

-file("src/lightspeed/data_plane_huge.gleam", 282).
?DOC(" `True` when the patch summary avoids full-root churn.\n").
-spec steady_state_no_full_root_churn(patch_summary()) -> boolean().
steady_state_no_full_root_churn(Summary) ->
    not erlang:element(4, Summary).

-file("src/lightspeed/data_plane_huge.gleam", 287).
?DOC(" `True` when ordering and sequence invariants hold for one window.\n").
-spec ordering_invariant(window()) -> boolean().
ordering_invariant(Window) ->
    case erlang:element(4, Window) =:= 0 of
        true ->
            (erlang:element(5, Window) =:= 0) andalso (erlang:element(6, Window)
            =:= 0);

        false ->
            ((erlang:element(5, Window) >= 1) andalso (erlang:element(6, Window)
            >= erlang:element(5, Window)))
            andalso (erlang:element(6, Window) =< erlang:element(4, Window))
    end andalso (erlang:element(8, Window) >= 0).

-file("src/lightspeed/data_plane_huge.gleam", 600).
-spec simulate_benchmark(binary(), plane(), burst_batch()) -> benchmark().
simulate_benchmark(Workload, Plane, Batch) ->
    Request = {window_request, 420000, 1200, 40},
    {_, Next_window, Patch} = apply_burst_updates(Plane, Request, Batch),
    Ordering_violations = case Next_window of
        {ok, Window} ->
            case ordering_invariant(Window) of
                true ->
                    0;

                false ->
                    1
            end;

        {error, _} ->
            1
    end,
    P50_latency = (20 + erlang:element(2, Patch)) + (erlang:element(
        4,
        erlang:element(7, Plane)
    )
    div 800),
    P95_latency = (P50_latency + 24) + (erlang:element(3, Batch) div 40),
    Throughput = max_int(
        60,
        (150 - (P95_latency div 3)) - (erlang:element(2, Patch) div 2)
    ),
    Full_root_churn_events = case erlang:element(4, Patch) of
        true ->
            1;

        false ->
            0
    end,
    {benchmark,
        Workload,
        P50_latency,
        P95_latency,
        erlang:element(3, Patch),
        erlang:element(2, Patch),
        Throughput,
        Full_root_churn_events,
        Ordering_violations}.

-file("src/lightspeed/data_plane_huge.gleam", 299).
?DOC(" Run deterministic heavy-data benchmarks.\n").
-spec run_huge_benchmarks() -> list(benchmark()).
run_huge_benchmarks() ->
    [simulate_benchmark(
            <<"million_grid_scroll"/utf8>>,
            million_row_plane(
                <<"#million-grid"/utf8>>,
                {million_row_grid, 12},
                default_transport_profile()
            ),
            burst_batch(<<"grid-a"/utf8>>, 420, 180, 120)
        ),
        simulate_benchmark(
            <<"burst_analytics_mix"/utf8>>,
            million_row_plane(
                <<"#burst-analytics"/utf8>>,
                {burst_analytics, 8},
                {transport_profile,
                    <<"sse_compact_json"/utf8>>,
                    <<"json"/utf8>>,
                    6144,
                    1500,
                    <<"columnar_json"/utf8>>}
            ),
            burst_batch(<<"analytics-a"/utf8>>, 620, 340, 160)
        ),
        simulate_benchmark(
            <<"longpoll_compact_view"/utf8>>,
            million_row_plane(
                <<"#longpoll-view"/utf8>>,
                million_row_list,
                {transport_profile,
                    <<"longpoll_compact_delta"/utf8>>,
                    <<"json"/utf8>>,
                    3072,
                    1200,
                    <<"delta_keys"/utf8>>}
            ),
            burst_batch(<<"lp-a"/utf8>>, 300, 120, 140)
        )].

-file("src/lightspeed/data_plane_huge.gleam", 344).
?DOC(" Default deterministic M51 budgets.\n").
-spec default_huge_budgets() -> list(budget()).
default_huge_budgets() ->
    [{budget, <<"million_grid_scroll"/utf8>>, 90, 2700, 28, 110, 0, 0},
        {budget, <<"burst_analytics_mix"/utf8>>, 105, 4200, 40, 95, 0, 0},
        {budget, <<"longpoll_compact_view"/utf8>>, 115, 3000, 32, 90, 0, 0}].

-file("src/lightspeed/data_plane_huge.gleam", 729).
-spec bool_label(boolean()) -> binary().
bool_label(Value) ->
    case Value of
        true ->
            <<"true"/utf8>>;

        false ->
            <<"false"/utf8>>
    end.

-file("src/lightspeed/data_plane_huge.gleam", 701).
-spec find_benchmark(list(benchmark()), binary()) -> {ok, benchmark()} |
    {error, binary()}.
find_benchmark(Benchmarks, Workload) ->
    case Benchmarks of
        [] ->
            {error, <<"missing_benchmark"/utf8>>};

        [Benchmark | Rest] ->
            case erlang:element(2, Benchmark) =:= Workload of
                true ->
                    {ok, Benchmark};

                false ->
                    find_benchmark(Rest, Workload)
            end
    end.

-file("src/lightspeed/data_plane_huge.gleam", 651).
-spec evaluate_one_budget(list(benchmark()), budget()) -> budget_result().
evaluate_one_budget(Benchmarks, Budget) ->
    case find_benchmark(Benchmarks, erlang:element(2, Budget)) of
        {error, Reason} ->
            {budget_result, erlang:element(2, Budget), false, Reason};

        {ok, 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),
            Throughput_ok = erlang:element(7, Benchmark) >= erlang:element(
                6,
                Budget
            ),
            Churn_ok = erlang:element(8, Benchmark) =< erlang:element(7, Budget),
            Ordering_ok = erlang:element(9, Benchmark) =< erlang:element(
                8,
                Budget
            ),
            Passed = ((((P95_ok andalso Payload_ok) andalso Patch_ok) andalso Throughput_ok)
            andalso Churn_ok)
            andalso Ordering_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,
                                                ",throughput="/utf8>>/binary,
                                            (bool_label(Throughput_ok))/binary>>/binary,
                                        ",churn="/utf8>>/binary,
                                    (bool_label(Churn_ok))/binary>>/binary,
                                ",ordering="/utf8>>/binary,
                            (bool_label(Ordering_ok))/binary>>
                end}
    end.

-file("src/lightspeed/data_plane_huge.gleam", 636).
-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/data_plane_huge.gleam", 377).
?DOC(" Evaluate huge-data benchmarks against one budget profile.\n").
-spec evaluate_huge_budgets(list(benchmark()), list(budget())) -> list(budget_result()).
evaluate_huge_budgets(Benchmarks, Budgets) ->
    evaluate_budget_loop(Benchmarks, Budgets, []).

-file("src/lightspeed/data_plane_huge.gleam", 385).
?DOC(" Count failing huge-data budgets.\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/data_plane_huge.gleam", 397).
?DOC(" Stable dataset label.\n").
-spec dataset_label(dataset()) -> binary().
dataset_label(Dataset) ->
    case Dataset of
        million_row_list ->
            <<"million_row_list"/utf8>>;

        {million_row_grid, Columns} ->
            <<"million_row_grid:"/utf8,
                (erlang:integer_to_binary(Columns))/binary>>;

        {burst_analytics, Cubes} ->
            <<"burst_analytics:"/utf8,
                (erlang:integer_to_binary(Cubes))/binary>>
    end.

-file("src/lightspeed/data_plane_huge.gleam", 406).
?DOC(" Stable transport-profile label.\n").
-spec transport_label(transport_profile()) -> binary().
transport_label(Profile) ->
    <<<<<<<<<<<<<<<<(erlang:element(2, Profile))/binary, "|encoding="/utf8>>/binary,
                                (erlang:element(3, Profile))/binary>>/binary,
                            "|frame="/utf8>>/binary,
                        (erlang:integer_to_binary(erlang:element(4, Profile)))/binary>>/binary,
                    "|chunk="/utf8>>/binary,
                (erlang:integer_to_binary(erlang:element(5, Profile)))/binary>>/binary,
            "|compact="/utf8>>/binary,
        (erlang:element(6, Profile))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 419).
?DOC(" Stable query-error label.\n").
-spec query_error_label(query_error()) -> binary().
query_error_label(Error) ->
    case Error of
        {invalid_window, Offset, Limit} ->
            <<<<<<"invalid_window:"/utf8,
                        (erlang:integer_to_binary(Offset))/binary>>/binary,
                    ":"/utf8>>/binary,
                (erlang:integer_to_binary(Limit))/binary>>;

        {sequence_regressed, Expected_min, Provided} ->
            <<<<<<"sequence_regressed:"/utf8,
                        (erlang:integer_to_binary(Expected_min))/binary>>/binary,
                    ":"/utf8>>/binary,
                (erlang:integer_to_binary(Provided))/binary>>
    end.

-file("src/lightspeed/data_plane_huge.gleam", 432).
?DOC(" Stable patch summary signature.\n").
-spec patch_summary_signature(patch_summary()) -> binary().
patch_summary_signature(Summary) ->
    <<<<<<<<<<<<<<"ops="/utf8,
                                (erlang:integer_to_binary(
                                    erlang:element(2, Summary)
                                ))/binary>>/binary,
                            "|payload="/utf8>>/binary,
                        (erlang:integer_to_binary(erlang:element(3, Summary)))/binary>>/binary,
                    "|full_root_churn="/utf8>>/binary,
                (bool_label(erlang:element(4, Summary)))/binary>>/binary,
            "|compact="/utf8>>/binary,
        (erlang:element(5, Summary))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 715).
-spec row_id(integer()) -> binary().
row_id(Index) ->
    case Index =< 0 of
        true ->
            <<"none"/utf8>>;

        false ->
            <<"row-"/utf8, (erlang:integer_to_binary(Index))/binary>>
    end.

-file("src/lightspeed/data_plane_huge.gleam", 444).
?DOC(" Stable window signature.\n").
-spec window_signature(window()) -> binary().
window_signature(Window) ->
    <<<<<<<<<<<<<<<<<<<<<<<<<<"offset="/utf8,
                                                        (erlang:integer_to_binary(
                                                            erlang:element(
                                                                2,
                                                                Window
                                                            )
                                                        ))/binary>>/binary,
                                                    "|limit="/utf8>>/binary,
                                                (erlang:integer_to_binary(
                                                    erlang:element(3, Window)
                                                ))/binary>>/binary,
                                            "|total="/utf8>>/binary,
                                        (erlang:integer_to_binary(
                                            erlang:element(4, Window)
                                        ))/binary>>/binary,
                                    "|first="/utf8>>/binary,
                                (row_id(erlang:element(5, Window)))/binary>>/binary,
                            "|last="/utf8>>/binary,
                        (row_id(erlang:element(6, Window)))/binary>>/binary,
                    "|version="/utf8>>/binary,
                (erlang:integer_to_binary(erlang:element(7, Window)))/binary>>/binary,
            "|sequence="/utf8>>/binary,
        (erlang:integer_to_binary(erlang:element(8, Window)))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 462).
?DOC(" Stable huge-plane signature.\n").
-spec signature(plane()) -> binary().
signature(Plane) ->
    <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<"target="/utf8,
                                                                        (erlang:element(
                                                                            2,
                                                                            Plane
                                                                        ))/binary>>/binary,
                                                                    "|dataset="/utf8>>/binary,
                                                                (dataset_label(
                                                                    erlang:element(
                                                                        3,
                                                                        Plane
                                                                    )
                                                                ))/binary>>/binary,
                                                            "|rows="/utf8>>/binary,
                                                        (erlang:integer_to_binary(
                                                            erlang:element(
                                                                4,
                                                                Plane
                                                            )
                                                        ))/binary>>/binary,
                                                    "|window_limit="/utf8>>/binary,
                                                (erlang:integer_to_binary(
                                                    erlang:element(5, Plane)
                                                ))/binary>>/binary,
                                            "|ordering_key="/utf8>>/binary,
                                        (erlang:element(6, Plane))/binary>>/binary,
                                    "|transport="/utf8>>/binary,
                                (transport_label(erlang:element(7, Plane)))/binary>>/binary,
                            "|version="/utf8>>/binary,
                        (erlang:integer_to_binary(erlang:element(8, Plane)))/binary>>/binary,
                    "|batches="/utf8>>/binary,
                (erlang:integer_to_binary(erlang:element(9, Plane)))/binary>>/binary,
            "|last_sequence="/utf8>>/binary,
        (erlang:integer_to_binary(erlang:element(10, Plane)))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 484).
?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,
                                            ":payload="/utf8>>/binary,
                                        (erlang:integer_to_binary(
                                            erlang:element(5, Benchmark)
                                        ))/binary>>/binary,
                                    ":patch_ops="/utf8>>/binary,
                                (erlang:integer_to_binary(
                                    erlang:element(6, Benchmark)
                                ))/binary>>/binary,
                            ":throughput="/utf8>>/binary,
                        (erlang:integer_to_binary(erlang:element(7, Benchmark)))/binary>>/binary,
                    ":root_churn="/utf8>>/binary,
                (erlang:integer_to_binary(erlang:element(8, Benchmark)))/binary>>/binary,
            ":ordering_violations="/utf8>>/binary,
        (erlang:integer_to_binary(erlang:element(9, Benchmark)))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 503).
?DOC(" Stable budget-result signature.\n").
-spec budget_result_signature(budget_result()) -> binary().
budget_result_signature(Result) ->
    <<<<<<<<(erlang:element(2, Result))/binary, ":passed="/utf8>>/binary,
                (bool_label(erlang:element(3, Result)))/binary>>/binary,
            ":reason="/utf8>>/binary,
        (erlang:element(4, Result))/binary>>.

-file("src/lightspeed/data_plane_huge.gleam", 512).
?DOC(" Plane target accessor.\n").
-spec target(plane()) -> binary().
target(Plane) ->
    erlang:element(2, Plane).

-file("src/lightspeed/data_plane_huge.gleam", 517).
?DOC(" Plane dataset accessor.\n").
-spec dataset(plane()) -> dataset().
dataset(Plane) ->
    erlang:element(3, Plane).

-file("src/lightspeed/data_plane_huge.gleam", 522).
?DOC(" Plane total rows accessor.\n").
-spec total_rows(plane()) -> integer().
total_rows(Plane) ->
    erlang:element(4, Plane).

-file("src/lightspeed/data_plane_huge.gleam", 527).
?DOC(" Plane transport profile accessor.\n").
-spec transport(plane()) -> transport_profile().
transport(Plane) ->
    erlang:element(7, Plane).

-file("src/lightspeed/data_plane_huge.gleam", 532).
?DOC(" Window sequence accessor.\n").
-spec window_sequence(window()) -> integer().
window_sequence(Window) ->
    erlang:element(8, Window).

-file("src/lightspeed/data_plane_huge.gleam", 537).
?DOC(" Window version accessor.\n").
-spec window_version(window()) -> integer().
window_version(Window) ->
    erlang:element(7, Window).