aion_flow

-module(aion@internal@ffi).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/aion/internal/ffi.gleam").
-export([dispatch_activity/3, dispatch_activity_in_vm/4, await_activity_result/1, workflow_id/0, now/0, random/0, random_int/2, sleep/1, start_timer/2, cancel_timer/1, with_timeout/2, continue_as_new/1, receive_signal/2, send_signal/3, register_query/2, reply_query/2, reply_query_error/2, dispatch_query/2, query_recorded_observations/0, spawn_child/3, await_child/1, collect_all/2, collect_race/2, collect_map/2, testing_reset/0, testing_advance/1, testing_register_activity_mock/2, testing_register_child_mock/2, testing_clear_observations/0, testing_observations/0, register_query_handler/2, service_query/1]).

-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(false).

-file("src/aion/internal/ffi.gleam", 18).
?DOC(false).
-spec dispatch_activity(binary(), binary(), binary()) -> {ok, binary()} |
    {error, binary()}.
dispatch_activity(Name, Input, Config) ->
    aion_flow_ffi:dispatch_activity(Name, Input, Config).

-file("src/aion/internal/ffi.gleam", 31).
?DOC(false).
-spec dispatch_activity_in_vm(
    binary(),
    binary(),
    binary(),
    fun(() -> {ok, binary()} | {error, binary()})
) -> {ok, binary()} | {error, binary()}.
dispatch_activity_in_vm(Name, Input, Config, Thunk) ->
    aion_flow_ffi:dispatch_activity_in_vm(Name, Input, Config, Thunk).

-file("src/aion/internal/ffi.gleam", 39).
?DOC(false).
-spec await_activity_result(binary()) -> {ok, binary()} | {error, binary()}.
await_activity_result(Correlation_id) ->
    aion_flow_ffi:await_activity_result(Correlation_id).

-file("src/aion/internal/ffi.gleam", 42).
?DOC(false).
-spec workflow_id() -> {ok, binary()} | {error, binary()}.
workflow_id() ->
    aion_flow_ffi:workflow_id().

-file("src/aion/internal/ffi.gleam", 45).
?DOC(false).
-spec now() -> {ok, binary()} | {error, binary()}.
now() ->
    aion_flow_ffi:now().

-file("src/aion/internal/ffi.gleam", 48).
?DOC(false).
-spec random() -> {ok, binary()} | {error, binary()}.
random() ->
    aion_flow_ffi:random().

-file("src/aion/internal/ffi.gleam", 51).
?DOC(false).
-spec random_int(binary(), binary()) -> {ok, binary()} | {error, binary()}.
random_int(Min, Max) ->
    aion_flow_ffi:random_int(Min, Max).

-file("src/aion/internal/ffi.gleam", 54).
?DOC(false).
-spec sleep(binary()) -> {ok, binary()} | {error, binary()}.
sleep(Duration) ->
    aion_flow_ffi:sleep(Duration).

-file("src/aion/internal/ffi.gleam", 57).
?DOC(false).
-spec start_timer(binary(), binary()) -> {ok, binary()} | {error, binary()}.
start_timer(Timer_id, Duration) ->
    aion_flow_ffi:start_timer(Timer_id, Duration).

-file("src/aion/internal/ffi.gleam", 60).
?DOC(false).
-spec cancel_timer(binary()) -> {ok, binary()} | {error, binary()}.
cancel_timer(Timer_id) ->
    aion_flow_ffi:cancel_timer(Timer_id).

-file("src/aion/internal/ffi.gleam", 63).
?DOC(false).
-spec with_timeout(binary(), fun(() -> {ok, ENV} | {error, ENW})) -> {ok,
        {ok, ENV} | {error, ENW}} |
    {error, binary()}.
with_timeout(Duration, Operation) ->
    aion_flow_ffi:with_timeout(Duration, Operation).

-file("src/aion/internal/ffi.gleam", 69).
?DOC(false).
-spec continue_as_new(binary()) -> {ok, nil} | {error, binary()}.
continue_as_new(Input) ->
    aion_flow_ffi:continue_as_new(Input).

-file("src/aion/internal/ffi.gleam", 72).
?DOC(false).
-spec receive_signal(binary(), binary()) -> {ok, binary()} | {error, binary()}.
receive_signal(Name, Config) ->
    aion_flow_ffi:receive_signal(Name, Config).

-file("src/aion/internal/ffi.gleam", 75).
?DOC(false).
-spec send_signal(binary(), binary(), binary()) -> {ok, binary()} |
    {error, binary()}.
send_signal(Workflow_id, Name, Payload) ->
    aion_flow_ffi:send_signal(Workflow_id, Name, Payload).

-file("src/aion/internal/ffi.gleam", 82).
?DOC(false).
-spec register_query(binary(), binary()) -> {ok, binary()} | {error, binary()}.
register_query(Name, Config) ->
    aion_flow_ffi:register_query(Name, Config).

-file("src/aion/internal/ffi.gleam", 85).
?DOC(false).
-spec reply_query(binary(), binary()) -> {ok, binary()} | {error, binary()}.
reply_query(Query_id, Payload) ->
    aion_flow_ffi:reply_query(Query_id, Payload).

-file("src/aion/internal/ffi.gleam", 88).
?DOC(false).
-spec reply_query_error(binary(), binary()) -> {ok, binary()} |
    {error, binary()}.
reply_query_error(Query_id, Message) ->
    aion_flow_ffi:reply_query_error(Query_id, Message).

-file("src/aion/internal/ffi.gleam", 94).
?DOC(false).
-spec dispatch_query(binary(), binary()) -> {ok, binary()} | {error, binary()}.
dispatch_query(Name, Config) ->
    aion_flow_ffi:dispatch_query(Name, Config).

-file("src/aion/internal/ffi.gleam", 97).
?DOC(false).
-spec query_recorded_observations() -> {ok, binary()} | {error, binary()}.
query_recorded_observations() ->
    aion_flow_ffi:query_recorded_observations().

-file("src/aion/internal/ffi.gleam", 100).
?DOC(false).
-spec spawn_child(binary(), binary(), binary()) -> {ok, binary()} |
    {error, binary()}.
spawn_child(Workflow_name, Input, Config) ->
    aion_flow_ffi:spawn_child(Workflow_name, Input, Config).

-file("src/aion/internal/ffi.gleam", 107).
?DOC(false).
-spec await_child(binary()) -> {ok, binary()} | {error, binary()}.
await_child(Child_id) ->
    aion_flow_ffi:await_child(Child_id).

-file("src/aion/internal/ffi.gleam", 110).
?DOC(false).
-spec collect_all(binary(), list(binary())) -> {ok, binary()} |
    {error, binary()}.
collect_all(Collection_id, Items) ->
    aion_flow_ffi:collect_all(Collection_id, Items).

-file("src/aion/internal/ffi.gleam", 116).
?DOC(false).
-spec collect_race(binary(), list(binary())) -> {ok, binary()} |
    {error, binary()}.
collect_race(Collection_id, Items) ->
    aion_flow_ffi:collect_race(Collection_id, Items).

-file("src/aion/internal/ffi.gleam", 122).
?DOC(false).
-spec collect_map(binary(), list(binary())) -> {ok, binary()} |
    {error, binary()}.
collect_map(Collection_id, Items) ->
    aion_flow_ffi:collect_map(Collection_id, Items).

-file("src/aion/internal/ffi.gleam", 128).
?DOC(false).
-spec testing_reset() -> {ok, binary()} | {error, binary()}.
testing_reset() ->
    aion_flow_ffi:testing_reset().

-file("src/aion/internal/ffi.gleam", 131).
?DOC(false).
-spec testing_advance(binary()) -> {ok, binary()} | {error, binary()}.
testing_advance(Duration) ->
    aion_flow_ffi:testing_advance(Duration).

-file("src/aion/internal/ffi.gleam", 134).
?DOC(false).
-spec testing_register_activity_mock(
    binary(),
    fun((binary()) -> {ok, binary()} | {error, binary()})
) -> {ok, binary()} | {error, binary()}.
testing_register_activity_mock(Name, Handler) ->
    aion_flow_ffi:testing_register_activity_mock(Name, Handler).

-file("src/aion/internal/ffi.gleam", 140).
?DOC(false).
-spec testing_register_child_mock(
    binary(),
    fun((binary()) -> {ok, binary()} | {error, binary()})
) -> {ok, binary()} | {error, binary()}.
testing_register_child_mock(Name, Handler) ->
    aion_flow_ffi:testing_register_child_mock(Name, Handler).

-file("src/aion/internal/ffi.gleam", 146).
?DOC(false).
-spec testing_clear_observations() -> {ok, binary()} | {error, binary()}.
testing_clear_observations() ->
    aion_flow_ffi:testing_clear_observations().

-file("src/aion/internal/ffi.gleam", 149).
?DOC(false).
-spec testing_observations() -> {ok, binary()} | {error, binary()}.
testing_observations() ->
    aion_flow_ffi:testing_observations().

-file("src/aion/internal/ffi.gleam", 155).
?DOC(false).
-spec register_query_handler(
    binary(),
    fun((binary()) -> {ok, binary()} | {error, binary()})
) -> nil.
register_query_handler(Name, Handler) ->
    aion_flow_query_pump:register(Name, Handler).

-file("src/aion/internal/ffi.gleam", 165).
?DOC(false).
-spec service_query(binary()) -> nil.
service_query(Sentinel_payload) ->
    aion_flow_query_pump:service(Sentinel_payload).