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

Inherits:

Object

Object
Temporalio::Client::Interceptor::Outbound

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

#next_interceptor ⇒ Outbound readonly
Next interceptor in the chain.

Instance Method Summary collapse

#backfill_schedule(input) ⇒ Object
Called for every ScheduleHandle#backfill call.
#cancel_activity(input) ⇒ Object
Called for every ActivityHandle#cancel call.
#cancel_workflow(input) ⇒ Object
Called for every WorkflowHandle#cancel call.
#complete_async_activity(input) ⇒ Object
Called for every AsyncActivityHandle#complete call.
#count_activities(input) ⇒ ActivityExecutionCount
Called for every Temporalio::Client#count_activities call.
#count_workflows(input) ⇒ WorkflowExecutionCount
Called for every Temporalio::Client#count_workflows call.
#create_schedule(input) ⇒ ScheduleHandle
Called for every Temporalio::Client#create_schedule call.
#delete_schedule(input) ⇒ Object
Called for every ScheduleHandle#delete call.
#describe_activity(input) ⇒ ActivityExecution::Description
Called for every ActivityHandle#describe call.
#describe_schedule(input) ⇒ Schedule::Description
Called for every ScheduleHandle#describe call.
#describe_workflow(input) ⇒ WorkflowExecution::Description
Called for every WorkflowHandle#describe call.
#fail_async_activity(input) ⇒ Object
Called for every AsyncActivityHandle#fail call.
#fetch_activity_outcome(input) ⇒ Api::Activity::V1::ActivityExecutionOutcome
Called by ActivityHandle#result to long-poll the activity outcome.
#fetch_workflow_history_events(input) ⇒ Enumerator<Api::History::V1::HistoryEvent>
Called everytime the client needs workflow history.
#heartbeat_async_activity(input) ⇒ Object
Called for every AsyncActivityHandle#heartbeat call.
#initialize(next_interceptor) ⇒ Outbound constructor
Initialize outbound with the next interceptor in the chain.
#list_activities(input) ⇒ Enumerator<ActivityExecution>
Called for every Temporalio::Client#list_activities call.
#list_schedules(input) ⇒ Enumerator<Schedule::List::Description>
Called for every Temporalio::Client#list_schedules call.
#list_workflow_page(input) ⇒ Client::ListWorkflowPage
Called for every Temporalio::Client#list_workflow_page call.
#pause_schedule(input) ⇒ Object
Called for every ScheduleHandle#pause call.
#poll_workflow_update(input) ⇒ Api::Update::V1::Outcome
Called when polling for update result.
#query_workflow(input) ⇒ Object^?
Called for every WorkflowHandle#query call.
#report_cancellation_async_activity(input) ⇒ Object
Called for every AsyncActivityHandle#report_cancellation call.
#signal_with_start_workflow(input) ⇒ WorkflowHandle
Called for every Temporalio::Client#signal_with_start_workflow.
#signal_workflow(input) ⇒ Object
Called for every WorkflowHandle#signal call.
#start_activity(input) ⇒ ActivityHandle
Called for every Temporalio::Client#start_activity and Temporalio::Client#execute_activity call.
#start_update_with_start_workflow(input) ⇒ WorkflowUpdateHandle
Called for every Temporalio::Client#start_update_with_start_workflow and Temporalio::Client#execute_update_with_start_workflow call.
#start_workflow(input) ⇒ WorkflowHandle
Called for every Temporalio::Client#start_workflow and Temporalio::Client#execute_workflow call.
#start_workflow_update(input) ⇒ WorkflowUpdateHandle
Called for every WorkflowHandle#start_update call.
#terminate_activity(input) ⇒ Object
Called for every ActivityHandle#terminate call.
#terminate_workflow(input) ⇒ Object
Called for every WorkflowHandle#terminate call.
#trigger_schedule(input) ⇒ Object
Called for every ScheduleHandle#trigger call.
#unpause_schedule(input) ⇒ Object
Called for every ScheduleHandle#unpause call.
#update_schedule(input) ⇒ Object
Called for every ScheduleHandle#update call.

Constructor Details

#initialize(next_interceptor) ⇒ `Outbound`

Initialize outbound with the next interceptor in the chain.

Parameters:

next_interceptor (Outbound) —
Next interceptor in the chain.



337
338
339

# File 'lib/temporalio/client/interceptor.rb', line 337

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.



332
333
334

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

def next_interceptor
  @next_interceptor
end

Instance Method Details

#backfill_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#backfill call.

Parameters:

input (BackfillScheduleInput) —
Input.



462
463
464

# File 'lib/temporalio/client/interceptor.rb', line 462

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

#cancel_activity(input) ⇒ `Object`

Called for every ActivityHandle#cancel call.

Parameters:

input (CancelActivityInput) —
Input.



556
557
558

# File 'lib/temporalio/client/interceptor.rb', line 556

def cancel_activity(input)
  next_interceptor.cancel_activity(input)
end

#cancel_workflow(input) ⇒ `Object`

Called for every WorkflowHandle#cancel call.

Parameters:

input (CancelWorkflowInput) —
Input.



432
433
434

# File 'lib/temporalio/client/interceptor.rb', line 432

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

#complete_async_activity(input) ⇒ `Object`

Called for every AsyncActivityHandle#complete call.

Parameters:

input (CompleteAsyncActivityInput) —
Input.



519
520
521

# File 'lib/temporalio/client/interceptor.rb', line 519

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

#count_activities(input) ⇒ `ActivityExecutionCount`

Called for every Temporalio::Client#count_activities call.

Parameters:

input (CountActivitiesInput) —
Input.

Returns:

(ActivityExecutionCount) —
Activity count.



579
580
581

# File 'lib/temporalio/client/interceptor.rb', line 579

def count_activities(input)
  next_interceptor.count_activities(input)
end

#count_workflows(input) ⇒ `WorkflowExecutionCount`

Called for every Temporalio::Client#count_workflows call.

Parameters:

input (CountWorkflowsInput) —
Input.

Returns:

(WorkflowExecutionCount) —
Workflow count.



378
379
380

# File 'lib/temporalio/client/interceptor.rb', line 378

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

#create_schedule(input) ⇒ `ScheduleHandle`

Called for every Temporalio::Client#create_schedule call.

Parameters:

input (CreateScheduleInput) —
Input.

Returns:

(ScheduleHandle) —
Schedule handle.



447
448
449

# File 'lib/temporalio/client/interceptor.rb', line 447

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

#delete_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#delete call.

Parameters:

input (DeleteScheduleInput) —
Input.



469
470
471

# File 'lib/temporalio/client/interceptor.rb', line 469

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

#describe_activity(input) ⇒ `ActivityExecution::Description`

Called for every ActivityHandle#describe call.

Parameters:

input (DescribeActivityInput) —
Input.

Returns:

(ActivityExecution::Description) —
Activity description.



549
550
551

# File 'lib/temporalio/client/interceptor.rb', line 549

def describe_activity(input)
  next_interceptor.describe_activity(input)
end

#describe_schedule(input) ⇒ `Schedule::Description`

Called for every ScheduleHandle#describe call.

Parameters:

input (DescribeScheduleInput) —
Input.

Returns:

(Schedule::Description) —
Schedule description.



477
478
479

# File 'lib/temporalio/client/interceptor.rb', line 477

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

#describe_workflow(input) ⇒ `WorkflowExecution::Description`

Called for every WorkflowHandle#describe call.

Parameters:

input (DescribeWorkflowInput) —
Input.

Returns:

(WorkflowExecution::Description) —
Workflow description.



386
387
388

# File 'lib/temporalio/client/interceptor.rb', line 386

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

#fail_async_activity(input) ⇒ `Object`

Called for every AsyncActivityHandle#fail call.

Parameters:

input (FailAsyncActivityInput) —
Input.



526
527
528

# File 'lib/temporalio/client/interceptor.rb', line 526

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

#fetch_activity_outcome(input) ⇒ `Api::Activity::V1::ActivityExecutionOutcome`

Called by ActivityHandle#result to long-poll the activity outcome.

Parameters:

input (FetchActivityOutcomeInput) —
Input.

Returns:

(Api::Activity::V1::ActivityExecutionOutcome) —
Activity outcome.



587
588
589

# File 'lib/temporalio/client/interceptor.rb', line 587

def fetch_activity_outcome(input)
  next_interceptor.fetch_activity_outcome(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:

input (FetchWorkflowHistoryEventsInput) —
Input.

Returns:

(Enumerator<Api::History::V1::HistoryEvent>) —
Event enumerator.



394
395
396

# File 'lib/temporalio/client/interceptor.rb', line 394

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:

input (HeartbeatAsyncActivityInput) —
Input.



512
513
514

# File 'lib/temporalio/client/interceptor.rb', line 512

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

#list_activities(input) ⇒ `Enumerator<ActivityExecution>`

Called for every Temporalio::Client#list_activities call.

Parameters:

input (ListActivitiesInput) —
Input.

Returns:

(Enumerator<ActivityExecution>) —
Activity executions.



571
572
573

# File 'lib/temporalio/client/interceptor.rb', line 571

def list_activities(input)
  next_interceptor.list_activities(input)
end

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

Called for every Temporalio::Client#list_schedules call.

Parameters:

input (ListSchedulesInput) —
Input.

Returns:

(Enumerator<Schedule::List::Description>) —
Enumerable schedules.



455
456
457

# File 'lib/temporalio/client/interceptor.rb', line 455

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

#list_workflow_page(input) ⇒ `Client::ListWorkflowPage`

Called for every Temporalio::Client#list_workflow_page call.

Parameters:

input (ListWorkflowPageInput) —
Input.

Returns:

(Client::ListWorkflowPage) —
Enumerable workflow executions, with a #next_page_token method.



370
371
372

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

def list_workflow_page(input)
  next_interceptor.list_workflow_page(input)
end

#pause_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#pause call.

Parameters:

input (PauseScheduleInput) —
Input.



484
485
486

# File 'lib/temporalio/client/interceptor.rb', line 484

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:

input (PollWorkflowUpdateInput) —
Input.

Returns:

(Api::Update::V1::Outcome) —
Update outcome.



425
426
427

# File 'lib/temporalio/client/interceptor.rb', line 425

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

#query_workflow(input) ⇒ `Object`^?

Called for every WorkflowHandle#query call.

Parameters:

input (QueryWorkflowInput) —
Input.

Returns:

(Object, nil) —
Query result.



409
410
411

# File 'lib/temporalio/client/interceptor.rb', line 409

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

#report_cancellation_async_activity(input) ⇒ `Object`

Called for every AsyncActivityHandle#report_cancellation call.

Parameters:

input (ReportCancellationAsyncActivityInput) —
Input.



533
534
535

# File 'lib/temporalio/client/interceptor.rb', line 533

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

#signal_with_start_workflow(input) ⇒ `WorkflowHandle`

Called for every Temporalio::Client#signal_with_start_workflow.

Parameters:

input (SignalWithStartWorkflowInput) —
Input.

Returns:

(WorkflowHandle) —
Workflow handle.



362
363
364

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

def signal_with_start_workflow(input)
  next_interceptor.signal_with_start_workflow(input)
end

#signal_workflow(input) ⇒ `Object`

Called for every WorkflowHandle#signal call.

Parameters:

input (SignalWorkflowInput) —
Input.



401
402
403

# File 'lib/temporalio/client/interceptor.rb', line 401

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

#start_activity(input) ⇒ `ActivityHandle`

Called for every Temporalio::Client#start_activity and Temporalio::Client#execute_activity call.

Parameters:

input (StartActivityInput) —
Input.

Returns:

(ActivityHandle) —
Activity handle.



541
542
543

# File 'lib/temporalio/client/interceptor.rb', line 541

def start_activity(input)
  next_interceptor.start_activity(input)
end

#start_update_with_start_workflow(input) ⇒ `WorkflowUpdateHandle`

Called for every Temporalio::Client#start_update_with_start_workflow and Temporalio::Client#execute_update_with_start_workflow call.

Parameters:

input (StartUpdateWithStartWorkflowInput) —
Input.

Returns:

(WorkflowUpdateHandle) —
Workflow update handle.



354
355
356

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

def start_update_with_start_workflow(input)
  next_interceptor.start_update_with_start_workflow(input)
end

#start_workflow(input) ⇒ `WorkflowHandle`

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

Parameters:

input (StartWorkflowInput) —
Input.

Returns:

(WorkflowHandle) —
Workflow handle.



345
346
347

# File 'lib/temporalio/client/interceptor.rb', line 345

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

#start_workflow_update(input) ⇒ `WorkflowUpdateHandle`

Called for every WorkflowHandle#start_update call.

Parameters:

input (StartWorkflowUpdateInput) —
Input.

Returns:

(WorkflowUpdateHandle) —
Update handle.



417
418
419

# File 'lib/temporalio/client/interceptor.rb', line 417

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

#terminate_activity(input) ⇒ `Object`

Called for every ActivityHandle#terminate call.

Parameters:

input (TerminateActivityInput) —
Input.



563
564
565

# File 'lib/temporalio/client/interceptor.rb', line 563

def terminate_activity(input)
  next_interceptor.terminate_activity(input)
end

#terminate_workflow(input) ⇒ `Object`

Called for every WorkflowHandle#terminate call.

Parameters:

input (TerminateWorkflowInput) —
Input.



439
440
441

# File 'lib/temporalio/client/interceptor.rb', line 439

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

#trigger_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#trigger call.

Parameters:

input (TriggerScheduleInput) —
Input.



491
492
493

# File 'lib/temporalio/client/interceptor.rb', line 491

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

#unpause_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#unpause call.

Parameters:

input (UnpauseScheduleInput) —
Input.



498
499
500

# File 'lib/temporalio/client/interceptor.rb', line 498

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

#update_schedule(input) ⇒ `Object`

Called for every ScheduleHandle#update call.

Parameters:

input (UpdateScheduleInput) —
Input.



505
506
507

# File 'lib/temporalio/client/interceptor.rb', line 505

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

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

Overview

Direct Known Subclasses

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(next_interceptor) ⇒ Outbound

Instance Attribute Details

#next_interceptor ⇒ Outbound (readonly)

Instance Method Details

#backfill_schedule(input) ⇒ Object

#cancel_activity(input) ⇒ Object

#cancel_workflow(input) ⇒ Object

#complete_async_activity(input) ⇒ Object

#count_activities(input) ⇒ ActivityExecutionCount

#count_workflows(input) ⇒ WorkflowExecutionCount

#create_schedule(input) ⇒ ScheduleHandle

#delete_schedule(input) ⇒ Object

#describe_activity(input) ⇒ ActivityExecution::Description

#describe_schedule(input) ⇒ Schedule::Description

#describe_workflow(input) ⇒ WorkflowExecution::Description

#fail_async_activity(input) ⇒ Object

#fetch_activity_outcome(input) ⇒ Api::Activity::V1::ActivityExecutionOutcome

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

#heartbeat_async_activity(input) ⇒ Object

#list_activities(input) ⇒ Enumerator<ActivityExecution>

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

#list_workflow_page(input) ⇒ Client::ListWorkflowPage

#pause_schedule(input) ⇒ Object

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

#query_workflow(input) ⇒ Object?

#report_cancellation_async_activity(input) ⇒ Object

#signal_with_start_workflow(input) ⇒ WorkflowHandle

#signal_workflow(input) ⇒ Object

#start_activity(input) ⇒ ActivityHandle

#start_update_with_start_workflow(input) ⇒ WorkflowUpdateHandle

#start_workflow(input) ⇒ WorkflowHandle

#start_workflow_update(input) ⇒ WorkflowUpdateHandle

#terminate_activity(input) ⇒ Object

#terminate_workflow(input) ⇒ Object

#trigger_schedule(input) ⇒ Object

#unpause_schedule(input) ⇒ Object

#update_schedule(input) ⇒ Object

#initialize(next_interceptor) ⇒ `Outbound`

#next_interceptor ⇒ `Outbound` (readonly)

#backfill_schedule(input) ⇒ `Object`

#cancel_activity(input) ⇒ `Object`

#cancel_workflow(input) ⇒ `Object`

#complete_async_activity(input) ⇒ `Object`

#count_activities(input) ⇒ `ActivityExecutionCount`

#count_workflows(input) ⇒ `WorkflowExecutionCount`

#create_schedule(input) ⇒ `ScheduleHandle`

#delete_schedule(input) ⇒ `Object`

#describe_activity(input) ⇒ `ActivityExecution::Description`

#describe_schedule(input) ⇒ `Schedule::Description`

#describe_workflow(input) ⇒ `WorkflowExecution::Description`

#fail_async_activity(input) ⇒ `Object`

#fetch_activity_outcome(input) ⇒ `Api::Activity::V1::ActivityExecutionOutcome`

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

#heartbeat_async_activity(input) ⇒ `Object`

#list_activities(input) ⇒ `Enumerator<ActivityExecution>`

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

#list_workflow_page(input) ⇒ `Client::ListWorkflowPage`

#pause_schedule(input) ⇒ `Object`

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

#query_workflow(input) ⇒ `Object`^?

#report_cancellation_async_activity(input) ⇒ `Object`

#signal_with_start_workflow(input) ⇒ `WorkflowHandle`

#signal_workflow(input) ⇒ `Object`

#start_activity(input) ⇒ `ActivityHandle`

#start_update_with_start_workflow(input) ⇒ `WorkflowUpdateHandle`

#start_workflow(input) ⇒ `WorkflowHandle`

#start_workflow_update(input) ⇒ `WorkflowUpdateHandle`

#terminate_activity(input) ⇒ `Object`

#terminate_workflow(input) ⇒ `Object`

#trigger_schedule(input) ⇒ `Object`

#unpause_schedule(input) ⇒ `Object`

#update_schedule(input) ⇒ `Object`