Class: Temporalio::Client::Interceptor::Outbound

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

Overview

Outbound interceptor for intercepting client calls. This should be extended by users needing to intercept client actions.

Direct Known Subclasses

Internal::Client::Implementation

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.



231
232
233
 
# File 'lib/temporalio/client/interceptor.rb', line 231

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.



226
227
228
 
# File 'lib/temporalio/client/interceptor.rb', line 226

def next_interceptor
  @next_interceptor
end

Instance Method Details

#backfill_schedule(input) ⇒ Object

Called for every ScheduleHandle#backfill call.

Parameters:



339
340
341
 
# File 'lib/temporalio/client/interceptor.rb', line 339

def backfill_schedule(input)
  next_interceptor.backfill_schedule(input)
end

#cancel_workflow(input) ⇒ Object

Called for every WorkflowHandle#cancel call.

Parameters:



309
310
311
 
# File 'lib/temporalio/client/interceptor.rb', line 309

def cancel_workflow(input)
  next_interceptor.cancel_workflow(input)
end

#complete_async_activity(input) ⇒ Object

Called for every AsyncActivityHandle#complete call.

Parameters:



396
397
398
 
# File 'lib/temporalio/client/interceptor.rb', line 396

def complete_async_activity(input)
  next_interceptor.complete_async_activity(input)
end

#count_workflows(input) ⇒ WorkflowExecutionCount

Called for every Temporalio::Client#count_workflows call.

Parameters:

Returns:



255
256
257
 
# File 'lib/temporalio/client/interceptor.rb', line 255

def count_workflows(input)
  next_interceptor.count_workflows(input)
end

#create_schedule(input) ⇒ ScheduleHandle

Called for every Temporalio::Client#create_schedule call.

Parameters:

Returns:



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

def create_schedule(input)
  next_interceptor.create_schedule(input)
end

#delete_schedule(input) ⇒ Object

Called for every ScheduleHandle#delete call.

Parameters:



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

def delete_schedule(input)
  next_interceptor.delete_schedule(input)
end

#describe_schedule(input) ⇒ Schedule::Description

Called for every ScheduleHandle#describe call.

Parameters:

Returns:



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

def describe_schedule(input)
  next_interceptor.describe_schedule(input)
end

#describe_workflow(input) ⇒ WorkflowExecution::Description

Called for every WorkflowHandle#describe call.

Parameters:

Returns:



263
264
265
 
# File 'lib/temporalio/client/interceptor.rb', line 263

def describe_workflow(input)
  next_interceptor.describe_workflow(input)
end

#fail_async_activity(input) ⇒ Object

Called for every AsyncActivityHandle#fail call.

Parameters:



403
404
405
 
# File 'lib/temporalio/client/interceptor.rb', line 403

def fail_async_activity(input)
  next_interceptor.fail_async_activity(input)
end

#fetch_workflow_history_events(input) ⇒ Enumerator<Api::History::V1::HistoryEvent>

Called everytime the client needs workflow history. This includes getting the result.

Parameters:

Returns:



271
272
273
 
# File 'lib/temporalio/client/interceptor.rb', line 271

def fetch_workflow_history_events(input)
  next_interceptor.fetch_workflow_history_events(input)
end

#heartbeat_async_activity(input) ⇒ Object

Called for every AsyncActivityHandle#heartbeat call.

Parameters:



389
390
391
 
# File 'lib/temporalio/client/interceptor.rb', line 389

def heartbeat_async_activity(input)
  next_interceptor.heartbeat_async_activity(input)
end

#list_schedules(input) ⇒ Enumerator<Schedule::List::Description>

Called for every Temporalio::Client#list_schedules call.

Parameters:

Returns:



332
333
334
 
# File 'lib/temporalio/client/interceptor.rb', line 332

def list_schedules(input)
  next_interceptor.list_schedules(input)
end

#list_workflows(input) ⇒ Enumerator<WorkflowExecution>

Called for every Temporalio::Client#list_workflows call.

Parameters:

Returns:



247
248
249
 
# File 'lib/temporalio/client/interceptor.rb', line 247

def list_workflows(input)
  next_interceptor.list_workflows(input)
end

#pause_schedule(input) ⇒ Object

Called for every ScheduleHandle#pause call.

Parameters:



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

def pause_schedule(input)
  next_interceptor.pause_schedule(input)
end

#poll_workflow_update(input) ⇒ Api::Update::V1::Outcome

Called when polling for update result.

Parameters:

Returns:



302
303
304
 
# File 'lib/temporalio/client/interceptor.rb', line 302

def poll_workflow_update(input)
  next_interceptor.poll_workflow_update(input)
end

#query_workflow(input) ⇒ Object?

Called for every WorkflowHandle#query call.

Parameters:

Returns:

  • (Object, nil) —

    Query result.



286
287
288
 
# File 'lib/temporalio/client/interceptor.rb', line 286

def query_workflow(input)
  next_interceptor.query_workflow(input)
end

#report_cancellation_async_activity(input) ⇒ Object

Called for every AsyncActivityHandle#report_cancellation call.

Parameters:



410
411
412
 
# File 'lib/temporalio/client/interceptor.rb', line 410

def report_cancellation_async_activity(input)
  next_interceptor.report_cancellation_async_activity(input)
end

#signal_workflow(input) ⇒ Object

Called for every WorkflowHandle#signal call.

Parameters:



278
279
280
 
# File 'lib/temporalio/client/interceptor.rb', line 278

def signal_workflow(input)
  next_interceptor.signal_workflow(input)
end

#start_workflow(input) ⇒ WorkflowHandle

Called for every Temporalio::Client#start_workflow and Temporalio::Client#execute_workflow call.

Parameters:

Returns:



239
240
241
 
# File 'lib/temporalio/client/interceptor.rb', line 239

def start_workflow(input)
  next_interceptor.start_workflow(input)
end

#start_workflow_update(input) ⇒ WorkflowUpdateHandle

Called for every WorkflowHandle#start_update call.

Parameters:

Returns:



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

def start_workflow_update(input)
  next_interceptor.start_workflow_update(input)
end

#terminate_workflow(input) ⇒ Object

Called for every WorkflowHandle#terminate call.

Parameters:



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

def terminate_workflow(input)
  next_interceptor.terminate_workflow(input)
end

#trigger_schedule(input) ⇒ Object

Called for every ScheduleHandle#trigger call.

Parameters:



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

def trigger_schedule(input)
  next_interceptor.trigger_schedule(input)
end

#unpause_schedule(input) ⇒ Object

Called for every ScheduleHandle#unpause call.

Parameters:



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

def unpause_schedule(input)
  next_interceptor.unpause_schedule(input)
end

#update_schedule(input) ⇒ Object

Called for every ScheduleHandle#update call.

Parameters:



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

def update_schedule(input)
  next_interceptor.update_schedule(input)
end