Module: Temporal

Extended by:
SingleForwardable
Defined in:
lib/temporal/thread_pool.rb,
lib/temporal.rb,
lib/temporal/json.rb,
lib/temporal/uuid.rb,
lib/temporal/types.rb,
lib/temporal/client.rb,
lib/temporal/errors.rb,
lib/temporal/logger.rb,
lib/temporal/worker.rb,
lib/temporal/metrics.rb,
lib/temporal/testing.rb,
lib/temporal/version.rb,
lib/temporal/activity.rb,
lib/temporal/metadata.rb,
lib/temporal/workflow.rb,
lib/temporal/saga/saga.rb,
lib/temporal/connection.rb,
lib/temporal/saga/result.rb,
lib/temporal/retry_policy.rb,
lib/temporal/saga/concern.rb,
lib/temporal/configuration.rb,
lib/temporal/error_handler.rb,
lib/temporal/metadata/base.rb,
lib/temporal/concerns/typed.rb,
lib/temporal/reset_strategy.rb,
lib/temporal/activity/poller.rb,
lib/temporal/connection/grpc.rb,
lib/temporal/workflow/errors.rb,
lib/temporal/workflow/future.rb,
lib/temporal/workflow/poller.rb,
lib/temporal/activity/context.rb,
lib/temporal/middleware/chain.rb,
lib/temporal/middleware/entry.rb,
lib/temporal/workflow/command.rb,
lib/temporal/workflow/context.rb,
lib/temporal/workflow/history.rb,
lib/temporal/concerns/payloads.rb,
lib/temporal/connection/errors.rb,
lib/temporal/executable_lookup.rb,
lib/temporal/execution_options.rb,
lib/temporal/metadata/activity.rb,
lib/temporal/metadata/workflow.rb,
lib/temporal/workflow/executor.rb,
lib/temporal/connection/retryer.rb,
lib/temporal/concerns/executable.rb,
lib/temporal/workflow/dispatcher.rb,
lib/temporal/activity/async_token.rb,
lib/temporal/metrics_adapters/log.rb,
lib/temporal/thread_local_context.rb,
lib/temporal/connection/serializer.rb,
lib/temporal/metrics_adapters/null.rb,
lib/temporal/metadata/workflow_task.rb,
lib/temporal/workflow/history/event.rb,
lib/temporal/workflow/state_manager.rb,
lib/temporal/activity/task_processor.rb,
lib/temporal/testing/future_registry.rb,
lib/temporal/workflow/execution_info.rb,
lib/temporal/workflow/history/window.rb,
lib/temporal/workflow/task_processor.rb,
lib/gen/temporal/api/enums/v1/query_pb.rb,
lib/temporal/connection/converter/base.rb,
lib/temporal/testing/temporal_override.rb,
lib/temporal/testing/workflow_override.rb,
lib/gen/temporal/api/enums/v1/common_pb.rb,
lib/temporal/connection/serializer/base.rb,
lib/temporal/testing/workflow_execution.rb,
lib/gen/temporal/api/query/v1/message_pb.rb,
lib/temporal/testing/scheduled_workflows.rb,
lib/gen/temporal/api/common/v1/message_pb.rb,
lib/gen/temporal/api/enums/v1/workflow_pb.rb,
lib/gen/temporal/api/filter/v1/message_pb.rb,
lib/temporal/workflow/convenience_methods.rb,
lib/temporal/workflow/replay_aware_logger.rb,
lib/gen/temporal/api/command/v1/message_pb.rb,
lib/gen/temporal/api/enums/v1/namespace_pb.rb,
lib/gen/temporal/api/failure/v1/message_pb.rb,
lib/gen/temporal/api/history/v1/message_pb.rb,
lib/gen/temporal/api/version/v1/message_pb.rb,
lib/temporal/connection/serializer/failure.rb,
lib/temporal/workflow/history/event_target.rb,
lib/gen/temporal/api/enums/v1/event_type_pb.rb,
lib/gen/temporal/api/enums/v1/task_queue_pb.rb,
lib/gen/temporal/api/workflow/v1/message_pb.rb,
lib/temporal/connection/converter/composite.rb,
lib/temporal/testing/local_activity_context.rb,
lib/temporal/testing/local_workflow_context.rb,
lib/temporal/workflow/command_state_machine.rb,
lib/gen/temporal/api/namespace/v1/message_pb.rb,
lib/gen/temporal/api/taskqueue/v1/message_pb.rb,
lib/gen/temporal/api/enums/v1/command_type_pb.rb,
lib/gen/temporal/api/enums/v1/failed_cause_pb.rb,
lib/temporal/connection/converter/payload/nil.rb,
lib/gen/temporal/api/replication/v1/message_pb.rb,
lib/temporal/connection/converter/payload/json.rb,
lib/temporal/connection/serializer/start_timer.rb,
lib/gen/temporal/api/errordetails/v1/message_pb.rb,
lib/temporal/connection/converter/payload/bytes.rb,
lib/temporal/connection/serializer/cancel_timer.rb,
lib/temporal/connection/serializer/retry_policy.rb,
lib/temporal/connection/serializer/fail_workflow.rb,
lib/temporal/connection/serializer/record_marker.rb,
lib/gen/temporal/api/workflowservice/v1/service_pb.rb,
lib/temporal/activity/workflow_convenience_methods.rb,
lib/temporal/connection/serializer/continue_as_new.rb,
lib/temporal/connection/serializer/complete_workflow.rb,
lib/temporal/connection/serializer/schedule_activity.rb,
lib/temporal/connection/serializer/start_child_workflow.rb,
lib/gen/temporal/api/workflowservice/v1/request_response_pb.rb,
lib/gen/temporal/api/workflowservice/v1/service_services_pb.rb,
lib/temporal/connection/serializer/request_activity_cancellation.rb

Overview

Provides context for Temporal::Activity::WorkflowConvenienceMethods

Defined Under Namespace

Modules: Api, Concerns, Connection, ErrorHandler, JSON, Metadata, MetricsAdapters, Middleware, ResetStrategy, Saga, Testing, ThreadLocalContext, Types, UUID Classes: Activity, ActivityCanceled, ActivityException, ActivityNotRegistered, ApiError, CancellationAlreadyRequestedFailure, Client, ClientError, ClientVersionNotSupportedFailure, Configuration, Error, ExecutableLookup, ExecutionOptions, FeatureVersionNotSupportedFailure, InternalError, Logger, Metrics, NamespaceAlreadyExistsFailure, NamespaceNotActiveFailure, NonDeterministicWorkflowError, NotFoundFailure, QueryFailedFailure, RetryPolicy, ThreadPool, TimeoutError, UnexpectedResponse, Worker, Workflow, WorkflowCanceled, WorkflowError, WorkflowExecutionAlreadyStartedFailure, WorkflowNotRegistered, WorkflowRunContinuedAsNew, WorkflowRunError, WorkflowTerminated, WorkflowTimedOut

Constant Summary collapse

VERSION =
'0.0.1'.freeze

Class Method Summary collapse

Class Method Details

.configurationObject


34
35
36
37
# File 'lib/temporal.rb', line 34

def configuration
  warn '[DEPRECATION] This method is now deprecated without a substitution'
  config
end

.configure {|config| ... } ⇒ Object

Yields:

  • (config)

30
31
32
# File 'lib/temporal.rb', line 30

def configure(&block)
  yield config
end

.loggerObject


39
40
41
# File 'lib/temporal.rb', line 39

def logger
  config.logger
end

.metricsObject


43
44
45
# File 'lib/temporal.rb', line 43

def metrics
  @metrics ||= Metrics.new(config.metrics_adapter)
end