Module: Temporalio

Defined in:

lib/temporalio.rb,
lib/temporalio/api.rb,
lib/temporalio/error.rb,
lib/temporalio/client.rb,
lib/temporalio/worker.rb,
lib/temporalio/runtime.rb,
lib/temporalio/testing.rb,
lib/temporalio/version.rb,
lib/temporalio/activity.rb,
lib/temporalio/internal.rb,
lib/temporalio/converters.rb,
lib/temporalio/cancellation.rb,
lib/temporalio/common_enums.rb,
lib/temporalio/retry_policy.rb,
lib/temporalio/worker/tuner.rb,
lib/temporalio/activity/info.rb,
lib/temporalio/error/failure.rb,
lib/temporalio/scoped_logger.rb,
lib/temporalio/internal/bridge.rb,
lib/temporalio/activity/context.rb,
lib/temporalio/workflow_history.rb,
lib/temporalio/client/connection.rb,
lib/temporalio/search_attributes.rb,
lib/temporalio/api/enums/v1/query.rb,
lib/temporalio/api/enums/v1/reset.rb,
lib/temporalio/client/interceptor.rb,
lib/temporalio/worker/interceptor.rb,
lib/temporalio/activity/definition.rb,
lib/temporalio/api/enums/v1/common.rb,
lib/temporalio/api/enums/v1/update.rb,
lib/temporalio/api/batch/v1/message.rb,
lib/temporalio/api/nexus/v1/message.rb,
lib/temporalio/api/query/v1/message.rb,
lib/temporalio/internal/proto_utils.rb,
lib/temporalio/api/common/v1/message.rb,
lib/temporalio/api/enums/v1/schedule.rb,
lib/temporalio/api/enums/v1/workflow.rb,
lib/temporalio/api/export/v1/message.rb,
lib/temporalio/api/filter/v1/message.rb,
lib/temporalio/api/update/v1/message.rb,
lib/temporalio/api/command/v1/message.rb,
lib/temporalio/api/enums/v1/namespace.rb,
lib/temporalio/api/failure/v1/message.rb,
lib/temporalio/api/history/v1/message.rb,
lib/temporalio/api/version/v1/message.rb,
lib/temporalio/client/workflow_handle.rb,
lib/temporalio/internal/bridge/client.rb,
lib/temporalio/internal/bridge/worker.rb,
lib/temporalio/api/enums/v1/event_type.rb,
lib/temporalio/api/enums/v1/task_queue.rb,
lib/temporalio/api/protocol/v1/message.rb,
lib/temporalio/api/schedule/v1/message.rb,
lib/temporalio/api/workflow/v1/message.rb,
lib/temporalio/internal/bridge/runtime.rb,
lib/temporalio/internal/bridge/testing.rb,
lib/temporalio/api/namespace/v1/message.rb,
lib/temporalio/api/sdk/v1/user_metadata.rb,
lib/temporalio/api/taskqueue/v1/message.rb,
lib/temporalio/converters/payload_codec.rb,
lib/temporalio/worker/activity_executor.rb,
lib/temporalio/api/common/v1/grpc_status.rb,
lib/temporalio/api/enums/v1/command_type.rb,
lib/temporalio/api/enums/v1/failed_cause.rb,
lib/temporalio/client/connection/service.rb,
lib/temporalio/client/workflow_execution.rb,
lib/temporalio/converters/data_converter.rb,
lib/temporalio/api/replication/v1/message.rb,
lib/temporalio/api/cloud/region/v1/message.rb,
lib/temporalio/api/errordetails/v1/message.rb,
lib/temporalio/api/enums/v1/batch_operation.rb,
lib/temporalio/api/sdk/v1/workflow_metadata.rb,
lib/temporalio/client/activity_id_reference.rb,
lib/temporalio/client/async_activity_handle.rb,
lib/temporalio/converters/failure_converter.rb,
lib/temporalio/converters/payload_converter.rb,
lib/temporalio/internal/worker/multi_runner.rb,
lib/temporalio/testing/activity_environment.rb,
lib/temporalio/testing/workflow_environment.rb,
lib/temporalio/activity/complete_async_error.rb,
lib/temporalio/api/cloud/identity/v1/message.rb,
lib/temporalio/client/workflow_update_handle.rb,
lib/temporalio/api/cloud/namespace/v1/message.rb,
lib/temporalio/api/cloud/operation/v1/message.rb,
lib/temporalio/api/operatorservice/v1/service.rb,
lib/temporalio/api/workflowservice/v1/service.rb,
lib/temporalio/internal/client/implementation.rb,
lib/temporalio/worker/activity_executor/fiber.rb,
lib/temporalio/api/sdk/v1/enhanced_stack_trace.rb,
lib/temporalio/client/connection/cloud_service.rb,
lib/temporalio/client/workflow_execution_count.rb,
lib/temporalio/internal/worker/activity_worker.rb,
lib/temporalio/client/workflow_execution_status.rb,
lib/temporalio/api/cloud/cloudservice/v1/service.rb,
lib/temporalio/api/sdk/v1/task_complete_metadata.rb,
lib/temporalio/client/workflow_update_wait_stage.rb,
lib/temporalio/internal/bridge/api/common/common.rb,
lib/temporalio/client/connection/operator_service.rb,
lib/temporalio/client/connection/workflow_service.rb,
lib/temporalio/internal/bridge/api/core_interface.rb,
lib/temporalio/worker/activity_executor/thread_pool.rb,
lib/temporalio/converters/payload_converter/encoding.rb,
lib/temporalio/client/workflow_query_reject_condition.rb,
lib/temporalio/converters/payload_converter/composite.rb,
lib/temporalio/api/operatorservice/v1/request_response.rb,
lib/temporalio/api/workflowservice/v1/request_response.rb,
lib/temporalio/converters/payload_converter/json_plain.rb,
lib/temporalio/converters/payload_converter/binary_null.rb,
lib/temporalio/converters/payload_converter/binary_plain.rb,
lib/temporalio/api/cloud/cloudservice/v1/request_response.rb,
lib/temporalio/converters/payload_converter/json_protobuf.rb,
lib/temporalio/converters/payload_converter/binary_protobuf.rb,
lib/temporalio/internal/bridge/api/activity_task/activity_task.rb,
lib/temporalio/internal/bridge/api/external_data/external_data.rb,
lib/temporalio/internal/bridge/api/child_workflow/child_workflow.rb,
lib/temporalio/internal/bridge/api/activity_result/activity_result.rb,
lib/temporalio/internal/bridge/api/workflow_commands/workflow_commands.rb,
lib/temporalio/internal/bridge/api/workflow_activation/workflow_activation.rb,
lib/temporalio/internal/bridge/api/workflow_completion/workflow_completion.rb

Overview

Much of this logic taken from github.com/ruby-concurrency/concurrent-ruby/blob/044020f44b36930b863b930f3ee8fa1e9f750469/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb, see MIT license at github.com/ruby-concurrency/concurrent-ruby/blob/044020f44b36930b863b930f3ee8fa1e9f750469/LICENSE.txt

Defined Under Namespace

Modules: Api, Converters, Testing, WorkflowIDConflictPolicy, WorkflowIDReusePolicy Classes: Activity, Cancellation, Client, Error, RetryPolicy, Runtime, ScopedLogger, SearchAttributes, Worker, WorkflowHistory

Constant Summary

VERSION =

'0.2.0'