Class TemporalClient

Namespace

Temporalio.Client

Assembly

Temporalio.dll

Client for a Temporal namespace.

public class TemporalClient : ITemporalClient, IWorkerClient

Inheritance

object

TemporalClient

Implements

ITemporalClient

IWorkerClient

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ITemporalClientExtensions.ExecuteWorkflowAsync(ITemporalClient, string, IReadOnlyCollection<object?>, WorkflowOptions)

ITemporalClientExtensions.ExecuteWorkflowAsync<TWorkflow>(ITemporalClient, Expression<Func<TWorkflow, Task>>, WorkflowOptions)

ITemporalClientExtensions.ExecuteWorkflowAsync<TResult>(ITemporalClient, string, IReadOnlyCollection<object?>, WorkflowOptions)

ITemporalClientExtensions.ExecuteWorkflowAsync<TWorkflow, TResult>(ITemporalClient, Expression<Func<TWorkflow, Task<TResult>>>, WorkflowOptions)

ITemporalClientExtensions.ListWorkflowHistoriesAsync(ITemporalClient, string, WorkflowListOptions?, WorkflowHistoryEventFetchOptions?)

Constructors

TemporalClient(ITemporalConnection, TemporalClientOptions)

Initializes a new instance of the TemporalClient class from an existing connection.

public TemporalClient(ITemporalConnection connection, TemporalClientOptions options)

Parameters

connection ITemporalConnection

Connection for this client.

options TemporalClientOptions

Options for this client.

Properties

BridgeClientProvider

Gets the bridge client provider for this client.

public IBridgeClientProvider BridgeClientProvider { get; }

Property Value

IBridgeClientProvider

Connection

Gets the connection associated with this client.

public ITemporalConnection Connection { get; }

Property Value

ITemporalConnection

Options

Gets the options used to create this client.

public TemporalClientOptions Options { get; }

Property Value

TemporalClientOptions

OutboundInterceptor

Gets the outbound interceptor in use.

public ClientOutboundInterceptor OutboundInterceptor { get; }

Property Value

ClientOutboundInterceptor

RetryRpcOptions

Gets a fixed set of retry-only RPC options.

protected static RpcOptions RetryRpcOptions { get; }

Property Value

RpcOptions

Methods

ConnectAsync(TemporalClientConnectOptions)

Connect to a Temporal namespace.

public static Task<TemporalClient> ConnectAsync(TemporalClientConnectOptions options)

Parameters

options TemporalClientConnectOptions

Options for connecting.

Returns

Task<TemporalClient>

The connected client.

CreateScheduleAsync(string, Schedule, ScheduleOptions?)

Create a schedule and return its handle.

public Task<ScheduleHandle> CreateScheduleAsync(string scheduleID, Schedule schedule, ScheduleOptions? options = null)

Parameters

scheduleID string

Unique ID for the schedule.

schedule Schedule

Schedule to create.

options ScheduleOptions

Options for creating the schedule.

Returns

Task<ScheduleHandle>

Handle to the created schedule.

Remarks

This can throw ScheduleAlreadyRunningException if the ID already exists.

DefaultRetryOptions(RpcOptions?)

Get a default set of retry options given the optional options. This will not mutate the given options. This only sets retry if original options are not present or they have not already set a retry.

protected static RpcOptions DefaultRetryOptions(RpcOptions? origOptions)

Parameters

origOptions RpcOptions

Original options to use as a base for the return.

Returns

RpcOptions

Options with default retry set.

GetAsyncActivityHandle(byte[])

Get a handle to complete an activity asynchronously using its task token.

public AsyncActivityHandle GetAsyncActivityHandle(byte[] taskToken)

Parameters

taskToken byte[]

Task token for the activity.

Returns

AsyncActivityHandle

Async activity handle.

GetAsyncActivityHandle(string, string, string)

Get a handle to complete an activity asynchronously using its qualified identifiers.

public AsyncActivityHandle GetAsyncActivityHandle(string workflowID, string runID, string activityID)

Parameters

workflowID string

ID for the activity's workflow.

runID string

Run ID for the activity's workflow.

activityID string

ID for the activity.

Returns

AsyncActivityHandle

Async activity handle.

GetScheduleHandle(string)

Gets the schedule handle for the given ID.

public ScheduleHandle GetScheduleHandle(string scheduleID)

Parameters

scheduleID string

Schedule ID to get the handle for.

Returns

ScheduleHandle

Schedule handle.

GetWorkflowHandle(string, string?, string?)

Get a workflow handle for an existing workflow with unknown return type.

public WorkflowHandle GetWorkflowHandle(string id, string? runID = null, string? firstExecutionRunID = null)

Parameters

id string

ID of the workflow.

runID string

Run ID of the workflow or null for latest.

firstExecutionRunID string

Optional first execution ID used for cancellation and termination.

Returns

WorkflowHandle

Created workflow handle.

GetWorkflowHandle<TWorkflow>(string, string?, string?)

Get a workflow handle for an existing workflow with known type.

public WorkflowHandle<TWorkflow> GetWorkflowHandle<TWorkflow>(string id, string? runID = null, string? firstExecutionRunID = null)

Parameters

id string

ID of the workflow.

runID string

Run ID of the workflow or null for latest.

firstExecutionRunID string

Optional first execution ID used for cancellation and termination.

Returns

WorkflowHandle<TWorkflow>

Created workflow handle.

Type Parameters

TWorkflow

Workflow class type.

GetWorkflowHandle<TWorkflow, TResult>(string, string?, string?)

Get a workflow handle for an existing workflow with known type and return type.

public WorkflowHandle<TWorkflow, TResult> GetWorkflowHandle<TWorkflow, TResult>(string id, string? runID = null, string? firstExecutionRunID = null)

Parameters

id string

ID of the workflow.

runID string

Run ID of the workflow or null for latest.

firstExecutionRunID string

Optional first execution ID used for cancellation and termination.

Returns

WorkflowHandle<TWorkflow, TResult>

Created workflow handle.

Type Parameters

TWorkflow

Workflow class type.

TResult

Result type of the workflow.

ListSchedulesAsync(ScheduleListOptions?)

List schedules.

public IAsyncEnumerable<ScheduleListDescription> ListSchedulesAsync(ScheduleListOptions? options = null)

Parameters

options ScheduleListOptions

Options for the list call.

Returns

IAsyncEnumerable<ScheduleListDescription>

Async enumerator for the schedules.

ListWorkflowsAsync(string, WorkflowListOptions?)

List workflows with the given query.

public IAsyncEnumerable<WorkflowExecution> ListWorkflowsAsync(string query, WorkflowListOptions? options = null)

Parameters

query string

Query to use for filtering.

options WorkflowListOptions

Options for the list call.

Returns

IAsyncEnumerable<WorkflowExecution>

Async enumerator for the workflows.

StartWorkflowAsync(string, IReadOnlyCollection<object?>, WorkflowOptions)

Start a workflow by name.

public Task<WorkflowHandle> StartWorkflowAsync(string workflow, IReadOnlyCollection<object?> args, WorkflowOptions options)

Parameters

workflow string

Workflow type name.

args IReadOnlyCollection<object>

Arguments for the workflow.

options WorkflowOptions

Start workflow options. ID and TaskQueue are required.

Returns

Task<WorkflowHandle>

Workflow handle for the started workflow.

Exceptions

ArgumentException

Invalid options.

WorkflowAlreadyStartedException

Workflow was already started according to ID reuse policy.

RpcException

Server-side error.

StartWorkflowAsync<TWorkflow>(Expression<Func<TWorkflow, Task>>, WorkflowOptions)

Start a workflow via lambda invoking the run method.

public Task<WorkflowHandle<TWorkflow>> StartWorkflowAsync<TWorkflow>(Expression<Func<TWorkflow, Task>> workflowRunCall, WorkflowOptions options)

Parameters

workflowRunCall Expression<Func<TWorkflow, Task>>

Invocation of workflow run method with no result.

options WorkflowOptions

Start workflow options. ID and TaskQueue are required.

Returns

Task<WorkflowHandle<TWorkflow>>

Workflow handle for the started workflow.

Type Parameters

TWorkflow

Workflow class type.

Exceptions

ArgumentException

Invalid run call or options.

WorkflowAlreadyStartedException

Workflow was already started according to ID reuse policy.

RpcException

Server-side error.

StartWorkflowAsync<TWorkflow, TResult>(Expression<Func<TWorkflow, Task<TResult>>>, WorkflowOptions)

Start a workflow via lambda invoking the run method.

public Task<WorkflowHandle<TWorkflow, TResult>> StartWorkflowAsync<TWorkflow, TResult>(Expression<Func<TWorkflow, Task<TResult>>> workflowRunCall, WorkflowOptions options)

Parameters

workflowRunCall Expression<Func<TWorkflow, Task<TResult>>>

Invocation of workflow run method with a result.

options WorkflowOptions

Start workflow options. ID and TaskQueue are required.

Returns

Task<WorkflowHandle<TWorkflow, TResult>>

Workflow handle for the started workflow.

Type Parameters

TWorkflow

Workflow class type.

TResult

Workflow result type.

Exceptions

ArgumentException

Invalid run call or options.

WorkflowAlreadyStartedException

Workflow was already started according to ID reuse policy.

RpcException

Server-side error.