Class ClientOutboundInterceptor
- Namespace
- Temporalio.Client.Interceptors
- Assembly
- Temporalio.dll
Base class for all outbound interceptors.
public abstract class ClientOutboundInterceptor
- Inheritance
-
ClientOutboundInterceptor
- Inherited Members
Constructors
ClientOutboundInterceptor(ClientOutboundInterceptor)
Initializes a new instance of the ClientOutboundInterceptor class.
protected ClientOutboundInterceptor(ClientOutboundInterceptor next)
Parameters
next
ClientOutboundInterceptorNext outbound interceptor in the chain.
Properties
Next
Gets the next interceptor in the chain.
protected ClientOutboundInterceptor Next { get; }
Property Value
Methods
BackfillScheduleAsync(BackfillScheduleInput)
Intercept backfill schedule calls.
public virtual Task BackfillScheduleAsync(BackfillScheduleInput input)
Parameters
input
BackfillScheduleInputInput details of the call.
Returns
- Task
Task for completion.
CancelWorkflowAsync(CancelWorkflowInput)
Intercept cancel workflow calls.
public virtual Task CancelWorkflowAsync(CancelWorkflowInput input)
Parameters
input
CancelWorkflowInputInput details of the call.
Returns
- Task
Task for acceptance of the cancel.
CompleteAsyncActivityAsync(CompleteAsyncActivityInput)
Intercept async activity complete calls.
public virtual Task CompleteAsyncActivityAsync(CompleteAsyncActivityInput input)
Parameters
input
CompleteAsyncActivityInputInput details of the call.
Returns
- Task
Task completion.
CountWorkflowsAsync(CountWorkflowsInput)
Intercept counting workflows.
public virtual Task<WorkflowExecutionCount> CountWorkflowsAsync(CountWorkflowsInput input)
Parameters
input
CountWorkflowsInputInput details of the call.
Returns
- Task<WorkflowExecutionCount>
Count information for the workflows.
CreateScheduleAsync(CreateScheduleInput)
Intercept create schedule calls.
public virtual Task<ScheduleHandle> CreateScheduleAsync(CreateScheduleInput input)
Parameters
input
CreateScheduleInputInput details of the call.
Returns
- Task<ScheduleHandle>
Schedule handle.
DeleteScheduleAsync(DeleteScheduleInput)
Intercept delete schedule calls.
public virtual Task DeleteScheduleAsync(DeleteScheduleInput input)
Parameters
input
DeleteScheduleInputInput details of the call.
Returns
- Task
Task for completion.
DescribeScheduleAsync(DescribeScheduleInput)
Intercept describe schedule calls.
public virtual Task<ScheduleDescription> DescribeScheduleAsync(DescribeScheduleInput input)
Parameters
input
DescribeScheduleInputInput details of the call.
Returns
- Task<ScheduleDescription>
Schedule description.
DescribeWorkflowAsync(DescribeWorkflowInput)
Intercept describe workflow calls.
public virtual Task<WorkflowExecutionDescription> DescribeWorkflowAsync(DescribeWorkflowInput input)
Parameters
input
DescribeWorkflowInputInput details of the call.
Returns
- Task<WorkflowExecutionDescription>
Workflow execution description.
FailAsyncActivityAsync(FailAsyncActivityInput)
Intercept async activity fail calls.
public virtual Task FailAsyncActivityAsync(FailAsyncActivityInput input)
Parameters
input
FailAsyncActivityInputInput details of the call.
Returns
- Task
Task completion.
FetchWorkflowHistoryEventPageAsync(FetchWorkflowHistoryEventPageInput)
Intercept a history event page fetch.
public virtual Task<WorkflowHistoryEventPage> FetchWorkflowHistoryEventPageAsync(FetchWorkflowHistoryEventPageInput input)
Parameters
input
FetchWorkflowHistoryEventPageInputInput details of the call.
Returns
- Task<WorkflowHistoryEventPage>
Event page. This will not return an empty event set and a next page token.
GetWorkerBuildIdCompatibilityAsync(GetWorkerBuildIdCompatibilityInput)
Intercept get worker build id compatability calls.
public virtual Task<WorkerBuildIdVersionSets?> GetWorkerBuildIdCompatibilityAsync(GetWorkerBuildIdCompatibilityInput input)
Parameters
input
GetWorkerBuildIdCompatibilityInputInput details of the call.
Returns
- Task<WorkerBuildIdVersionSets>
The sets, if the Task Queue is versioned, otherwise null.
GetWorkerTaskReachabilityAsync(GetWorkerTaskReachabilityInput)
Intercept get worker build id compatability calls.
public virtual Task<WorkerTaskReachability> GetWorkerTaskReachabilityAsync(GetWorkerTaskReachabilityInput input)
Parameters
input
GetWorkerTaskReachabilityInputInput details of the call.
Returns
- Task<WorkerTaskReachability>
The reachability information.
HeartbeatAsyncActivityAsync(HeartbeatAsyncActivityInput)
Intercept async activity heartbeat calls.
public virtual Task HeartbeatAsyncActivityAsync(HeartbeatAsyncActivityInput input)
Parameters
input
HeartbeatAsyncActivityInputInput details of the call.
Returns
- Task
Task completion.
ListSchedulesAsync(ListSchedulesInput)
Intercept list schedules calls.
public virtual IAsyncEnumerable<ScheduleListDescription> ListSchedulesAsync(ListSchedulesInput input)
Parameters
input
ListSchedulesInputInput details of the call.
Returns
- IAsyncEnumerable<ScheduleListDescription>
Schedule enumerable.
ListWorkflowsAsync(ListWorkflowsInput)
Intercept listing workflows.
public virtual IAsyncEnumerable<WorkflowExecution> ListWorkflowsAsync(ListWorkflowsInput input)
Parameters
input
ListWorkflowsInputInput details of the call.
Returns
- IAsyncEnumerable<WorkflowExecution>
Async enumerator for the workflows.
PauseScheduleAsync(PauseScheduleInput)
Intercept pause schedule calls.
public virtual Task PauseScheduleAsync(PauseScheduleInput input)
Parameters
input
PauseScheduleInputInput details of the call.
Returns
- Task
Task for completion.
QueryWorkflowAsync<TResult>(QueryWorkflowInput)
Intercept query workflow calls.
public virtual Task<TResult> QueryWorkflowAsync<TResult>(QueryWorkflowInput input)
Parameters
input
QueryWorkflowInputInput details of the call.
Returns
- Task<TResult>
Result of the query.
Type Parameters
TResult
Return type of the query.
ReportCancellationAsyncActivityAsync(ReportCancellationAsyncActivityInput)
Intercept async activity report cancellation calls.
public virtual Task ReportCancellationAsyncActivityAsync(ReportCancellationAsyncActivityInput input)
Parameters
input
ReportCancellationAsyncActivityInputInput details of the call.
Returns
- Task
Task completion.
SignalWorkflowAsync(SignalWorkflowInput)
Intercept signal workflow calls.
public virtual Task SignalWorkflowAsync(SignalWorkflowInput input)
Parameters
input
SignalWorkflowInputInput details of the call.
Returns
- Task
Task for acceptance of the signal.
StartWorkflowAsync<TWorkflow, TResult>(StartWorkflowInput)
Intercept start workflow calls.
public virtual Task<WorkflowHandle<TWorkflow, TResult>> StartWorkflowAsync<TWorkflow, TResult>(StartWorkflowInput input)
Parameters
input
StartWorkflowInputInput details of the call.
Returns
- Task<WorkflowHandle<TWorkflow, TResult>>
Handle for the workflow.
Type Parameters
TWorkflow
Workflow class type. May be ValueTuple if unknown.
TResult
Result type of the workflow. May be ValueTuple if unknown.
StartWorkflowUpdateAsync<TResult>(StartWorkflowUpdateInput)
Intercept start workflow update calls.
public virtual Task<WorkflowUpdateHandle<TResult>> StartWorkflowUpdateAsync<TResult>(StartWorkflowUpdateInput input)
Parameters
input
StartWorkflowUpdateInputInput details of the call.
Returns
- Task<WorkflowUpdateHandle<TResult>>
Handle for the update.
Type Parameters
TResult
Return type of the update. This may be ValueTuple if user is discarding result.
TerminateWorkflowAsync(TerminateWorkflowInput)
Intercept terminate workflow calls.
public virtual Task TerminateWorkflowAsync(TerminateWorkflowInput input)
Parameters
input
TerminateWorkflowInputInput details of the call.
Returns
- Task
Task for termination completion.
TriggerScheduleAsync(TriggerScheduleInput)
Intercept trigger schedule calls.
public virtual Task TriggerScheduleAsync(TriggerScheduleInput input)
Parameters
input
TriggerScheduleInputInput details of the call.
Returns
- Task
Task for completion.
UnpauseScheduleAsync(UnpauseScheduleInput)
Intercept unpause schedule calls.
public virtual Task UnpauseScheduleAsync(UnpauseScheduleInput input)
Parameters
input
UnpauseScheduleInputInput details of the call.
Returns
- Task
Task for completion.
UpdateScheduleAsync(UpdateScheduleInput)
Intercept update schedule calls.
public virtual Task UpdateScheduleAsync(UpdateScheduleInput input)
Parameters
input
UpdateScheduleInputInput details of the call.
Returns
- Task
Task for completion.
UpdateWorkerBuildIdCompatibilityAsync(UpdateWorkerBuildIdCompatibilityInput)
Intercept update worker build id compatability calls.
public virtual Task UpdateWorkerBuildIdCompatibilityAsync(UpdateWorkerBuildIdCompatibilityInput input)
Parameters
input
UpdateWorkerBuildIdCompatibilityInputInput details of the call.
Returns
- Task
Completion task.