TemporalSdk.Activity (temporal_sdk v0.2.11)
View SourceTemporal activity task module.
Summary
Functions
@spec await_data(ets_pattern :: term()) :: {:ok, :temporal_sdk_activity.data()} | :timeout | :invalid_pattern | no_return()
@spec await_data(ets_pattern :: term(), timeout :: :erlang.timeout()) :: {:ok, :temporal_sdk_activity.data()} | :timeout | :invalid_pattern | no_return()
@spec cancel(canceled_details :: :temporal_sdk.term_to_payloads()) :: no_return()
@spec complete(result :: :temporal_sdk.term_to_payloads()) :: no_return()
@spec elapsed_time() :: native_time :: non_neg_integer() | no_return()
@spec elapsed_time(unit :: :erlang.time_unit()) :: non_neg_integer() | no_return()
@spec fail( application_failure :: :temporal_sdk.application_failure() | :temporal_sdk.application_failure_as_list() ) :: no_return()
@spec fail( class :: :error | :exit | :throw | :temporal_sdk.serializable(), reason :: term() | :temporal_sdk.serializable(), stacktrace :: :erlang.raise_stacktrace() | :temporal_sdk.serializable() ) :: no_return()
@spec get_data() :: data :: :temporal_sdk_activity.data() | no_return()
@spec heartbeat() :: :ok
@spec heartbeat(heartbeat :: :temporal_sdk_activity.heartbeat()) :: :ok
@spec last_heartbeat() :: last_heartbeat :: :temporal_sdk_activity.heartbeat() | no_return()
@spec remaining_time() :: native_time :: non_neg_integer() | :infinity | no_return()
@spec remaining_time(unit :: :erlang.time_unit()) :: non_neg_integer() | :infinity | no_return()
@spec set_data(task_data :: term()) :: :ok