Class: Temporalio::Worker::Interceptor::Workflow::Outbound

Inherits:
Object
  • Object
show all
Defined in:
lib/temporalio/worker/interceptor.rb

Overview

Outbound interceptor for intercepting outbound workflow calls. This should be extended by users needing to intercept workflow calls.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(next_interceptor) ⇒ Outbound

Initialize outbound with the next interceptor in the chain.

Parameters:

  • next_interceptor (Outbound) —

    Next interceptor in the chain.



331
332
333
 
# File 'lib/temporalio/worker/interceptor.rb', line 331

def initialize(next_interceptor)
  @next_interceptor = next_interceptor
end

Instance Attribute Details

#next_interceptor ⇒ Outbound (readonly)

Returns Next interceptor in the chain.

Returns:

  • (Outbound) —

    Next interceptor in the chain.



326
327
328
 
# File 'lib/temporalio/worker/interceptor.rb', line 326

def next_interceptor
  @next_interceptor
end

Instance Method Details

#cancel_external_workflow(input) ⇒ Object

Cancel external workflow.

Parameters:



338
339
340
 
# File 'lib/temporalio/worker/interceptor.rb', line 338

def cancel_external_workflow(input)
  @next_interceptor.cancel_external_workflow(input)
end

#execute_activity(input) ⇒ Object

Execute activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



346
347
348
 
# File 'lib/temporalio/worker/interceptor.rb', line 346

def execute_activity(input)
  @next_interceptor.execute_activity(input)
end

#execute_local_activity(input) ⇒ Object

Execute local activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



354
355
356
 
# File 'lib/temporalio/worker/interceptor.rb', line 354

def execute_local_activity(input)
  @next_interceptor.execute_local_activity(input)
end

#initialize_continue_as_new_error(input) ⇒ Object

Initialize continue as new error.

Parameters:



361
362
363
 
# File 'lib/temporalio/worker/interceptor.rb', line 361

def initialize_continue_as_new_error(input)
  @next_interceptor.initialize_continue_as_new_error(input)
end

#signal_child_workflow(input) ⇒ Object

Signal child workflow.

Parameters:



368
369
370
 
# File 'lib/temporalio/worker/interceptor.rb', line 368

def signal_child_workflow(input)
  @next_interceptor.signal_child_workflow(input)
end

#signal_external_workflow(input) ⇒ Object

Signal external workflow.

Parameters:



375
376
377
 
# File 'lib/temporalio/worker/interceptor.rb', line 375

def signal_external_workflow(input)
  @next_interceptor.signal_external_workflow(input)
end

#sleep(input) ⇒ Object

Sleep.

Parameters:



382
383
384
 
# File 'lib/temporalio/worker/interceptor.rb', line 382

def sleep(input)
  @next_interceptor.sleep(input)
end

#start_child_workflow(input) ⇒ Workflow::ChildWorkflowHandle

Start child workflow.

Parameters:

Returns:



390
391
392
 
# File 'lib/temporalio/worker/interceptor.rb', line 390

def start_child_workflow(input)
  @next_interceptor.start_child_workflow(input)
end

#start_nexus_operation(input) ⇒ Workflow::NexusOperationHandle

Start Nexus operation.

WARNING: Nexus support is experimental.

Parameters:

Returns:



400
401
402
 
# File 'lib/temporalio/worker/interceptor.rb', line 400

def start_nexus_operation(input)
  @next_interceptor.start_nexus_operation(input)
end