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.



301
302
303
 
# File 'lib/temporalio/worker/interceptor.rb', line 301

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.



296
297
298
 
# File 'lib/temporalio/worker/interceptor.rb', line 296

def next_interceptor
  @next_interceptor
end

Instance Method Details

#cancel_external_workflow(input) ⇒ Object

Cancel external workflow.

Parameters:



308
309
310
 
# File 'lib/temporalio/worker/interceptor.rb', line 308

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

#execute_activity(input) ⇒ Object

Execute activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



316
317
318
 
# File 'lib/temporalio/worker/interceptor.rb', line 316

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

#execute_local_activity(input) ⇒ Object

Execute local activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



324
325
326
 
# File 'lib/temporalio/worker/interceptor.rb', line 324

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:



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

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:



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

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

#signal_external_workflow(input) ⇒ Object

Signal external workflow.

Parameters:



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

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

#sleep(input) ⇒ Object

Sleep.

Parameters:



352
353
354
 
# File 'lib/temporalio/worker/interceptor.rb', line 352

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

#start_child_workflow(input) ⇒ Workflow::ChildWorkflowHandle

Start child workflow.

Parameters:

Returns:



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

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