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.



299
300
301
 
# File 'lib/temporalio/worker/interceptor.rb', line 299

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.



294
295
296
 
# File 'lib/temporalio/worker/interceptor.rb', line 294

def next_interceptor
  @next_interceptor
end

Instance Method Details

#cancel_external_workflow(input) ⇒ Object

Cancel external workflow.

Parameters:



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

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

#execute_activity(input) ⇒ Object

Execute activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



314
315
316
 
# File 'lib/temporalio/worker/interceptor.rb', line 314

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

#execute_local_activity(input) ⇒ Object

Execute local activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



322
323
324
 
# File 'lib/temporalio/worker/interceptor.rb', line 322

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:



329
330
331
 
# File 'lib/temporalio/worker/interceptor.rb', line 329

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:



336
337
338
 
# File 'lib/temporalio/worker/interceptor.rb', line 336

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

#signal_external_workflow(input) ⇒ Object

Signal external workflow.

Parameters:



343
344
345
 
# File 'lib/temporalio/worker/interceptor.rb', line 343

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

#sleep(input) ⇒ Object

Sleep.

Parameters:



350
351
352
 
# File 'lib/temporalio/worker/interceptor.rb', line 350

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

#start_child_workflow(input) ⇒ Workflow::ChildWorkflowHandle

Start child workflow.

Parameters:

Returns:



358
359
360
 
# File 'lib/temporalio/worker/interceptor.rb', line 358

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