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.



311
312
313
 
# File 'lib/temporalio/worker/interceptor.rb', line 311

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.



306
307
308
 
# File 'lib/temporalio/worker/interceptor.rb', line 306

def next_interceptor
  @next_interceptor
end

Instance Method Details

#cancel_external_workflow(input) ⇒ Object

Cancel external workflow.

Parameters:



318
319
320
 
# File 'lib/temporalio/worker/interceptor.rb', line 318

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

#execute_activity(input) ⇒ Object

Execute activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



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

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

#execute_local_activity(input) ⇒ Object

Execute local activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



334
335
336
 
# File 'lib/temporalio/worker/interceptor.rb', line 334

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:



341
342
343
 
# File 'lib/temporalio/worker/interceptor.rb', line 341

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:



348
349
350
 
# File 'lib/temporalio/worker/interceptor.rb', line 348

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

#signal_external_workflow(input) ⇒ Object

Signal external workflow.

Parameters:



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

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

#sleep(input) ⇒ Object

Sleep.

Parameters:



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

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

#start_child_workflow(input) ⇒ Workflow::ChildWorkflowHandle

Start child workflow.

Parameters:

Returns:



370
371
372
 
# File 'lib/temporalio/worker/interceptor.rb', line 370

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