Packages

temporal_sdk

0.1.14
0.2.20 0.2.11 0.2.2 0.2.1 0.2.0 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.1 0.1.0

Temporal Erlang/Elixir SDK

HexDocs

Current section

Files

Jump to
Readme
15 Versions
5 Dependencies
Dependants
Files
Activity
temporal_sdk src poller temporal_sdk_poller_adapter.erl
Raw

src/poller/temporal_sdk_poller_adapter.erl 

-module(temporal_sdk_poller_adapter).



% elp:ignore W0012 W0040

-moduledoc false.



-export([

    handle_poll/1,

    handle_execute/2

]).



-callback handle_poll(ApiContext :: temporal_sdk_api:context()) ->

    temporal_sdk_client:msg_result().



-callback handle_execute(

    ApiContext :: temporal_sdk_api:context(),

    Task :: temporal_sdk_activity:task() | temporal_sdk_workflow:task()

) -> {ok, Status :: executed | redirected} | {error, Reason :: term()}.



-spec handle_poll(ApiContext :: temporal_sdk_api:context()) -> temporal_sdk_client:msg_result().

handle_poll(#{worker_type := WorkerType} = ApiContext) ->

    M = get_module(WorkerType),

    M:handle_poll(ApiContext).



-spec handle_execute(

    ApiContext :: temporal_sdk_api:context(),

    Task :: temporal_sdk_activity:task() | temporal_sdk_workflow:task()

) -> {ok, Status :: executed | redirected} | {error, Reason :: term()}.

handle_execute(#{worker_type := WorkerType} = ApiContext, Task) ->

    M = get_module(WorkerType),

    M:handle_execute(ApiContext, Task).



get_module(activity) -> temporal_sdk_poller_adapter_activity_task_queue;

get_module(nexus) -> temporal_sdk_poller_adapter_nexus_task_queue;

get_module(session) -> temporal_sdk_poller_adapter_activity_task_queue;

get_module(workflow) -> temporal_sdk_poller_adapter_workflow_task_queue.