Module: Temporal::Client::Serializer

Defined in:
lib/temporal/client/serializer.rb,
lib/temporal/client/serializer/base.rb,
lib/temporal/client/serializer/failure.rb,
lib/temporal/client/serializer/start_timer.rb,
lib/temporal/client/serializer/cancel_timer.rb,
lib/temporal/client/serializer/retry_policy.rb,
lib/temporal/client/serializer/fail_workflow.rb,
lib/temporal/client/serializer/record_marker.rb,
lib/temporal/client/serializer/continue_as_new.rb,
lib/temporal/client/serializer/complete_workflow.rb,
lib/temporal/client/serializer/schedule_activity.rb,
lib/temporal/client/serializer/start_child_workflow.rb,
lib/temporal/client/serializer/request_activity_cancellation.rb

Defined Under Namespace

Classes: Base, CancelTimer, CompleteWorkflow, ContinueAsNew, FailWorkflow, Failure, RecordMarker, RequestActivityCancellation, RetryPolicy, ScheduleActivity, StartChildWorkflow, StartTimer

Constant Summary collapse

SERIALIZERS_MAP = 
{
  Workflow::Command::ScheduleActivity => Serializer::ScheduleActivity,
  Workflow::Command::StartChildWorkflow => Serializer::StartChildWorkflow,
  Workflow::Command::RequestActivityCancellation => Serializer::RequestActivityCancellation,
  Workflow::Command::RecordMarker => Serializer::RecordMarker,
  Workflow::Command::StartTimer => Serializer::StartTimer,
  Workflow::Command::CancelTimer => Serializer::CancelTimer,
  Workflow::Command::CompleteWorkflow => Serializer::CompleteWorkflow,
  Workflow::Command::ContinueAsNew => Serializer::ContinueAsNew,
  Workflow::Command::FailWorkflow => Serializer::FailWorkflow
}.freeze

Class Method Summary collapse

Class Method Details

.serialize(object) ⇒ Object 



27
28
29
30
 
# File 'lib/temporal/client/serializer.rb', line 27

def self.serialize(object)
  serializer = SERIALIZERS_MAP[object.class]
  serializer.new(object).to_proto
end