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.



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

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.



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

def next_interceptor
  @next_interceptor
end

Instance Method Details

#cancel_external_workflow(input) ⇒ Object

Cancel external workflow.

Parameters:



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

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

#execute_activity(input) ⇒ Object

Execute activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



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

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

#execute_local_activity(input) ⇒ Object

Execute local activity.

Parameters:

Returns:

  • (Object) —

    Activity result.



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

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:



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

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:



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

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

#signal_external_workflow(input) ⇒ Object

Signal external workflow.

Parameters:



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

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

#sleep(input) ⇒ Object

Sleep.

Parameters:



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

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

#start_child_workflow(input) ⇒ Workflow::ChildWorkflowHandle

Start child workflow.

Parameters:

Returns:



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

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