Class TemporalClientService

Temporal Client Service

Provides a clean interface for Temporal client operations including:

Workflow execution (start, terminate, cancel)
Signal and query operations
Workflow handle management
Client health monitoring

Example

// Start a workflow
const handle = await clientService.startWorkflow('myWorkflow', { data: 'example' });

// Send a signal
await clientService.signalWorkflow(handle, 'updateData', 'new data');

// Query workflow state
const result = await clientService.queryWorkflow(handle, 'getStatus');

Implements

OnModuleInit

Index

Constructors

constructor

Methods

cancelWorkflow getHealth getRawClient getStatus getWorkflowHandle getWorkflowResult isHealthy onModuleInit queryWorkflow queryWorkflowHandle signalWorkflow signalWorkflowHandle startWorkflow terminateWorkflow

Constructors

constructor

new TemporalClientService(
temporalClient: Client | null,
options: TemporalOptions,
): TemporalClientService
Parameters
- temporalClient: Client | null
- options: TemporalOptions
Returns TemporalClientService
- Defined in src/services/temporal-client.service.ts:46

Methods

cancelWorkflow

cancelWorkflow(workflowId: string, runId?: string): Promise<void>
Cancel a workflow execution
Parameters
- workflowId: string
- OptionalrunId: string
Returns Promise<void>
- Defined in src/services/temporal-client.service.ts:215

getHealth

getHealth(): ClientHealthStatus
Get client health status

Returns ClientHealthStatus
- Defined in src/services/temporal-client.service.ts:354

getRawClient

getRawClient(): Client | null
Get raw Temporal client (use with caution)

Returns Client | null
- Defined in src/services/temporal-client.service.ts:374

getStatus

getStatus(): ClientServiceStatus
Get client status for monitoring

Returns ClientServiceStatus
- Defined in src/services/temporal-client.service.ts:361

getWorkflowHandle

getWorkflowHandle(
workflowId: string,
runId?: string,
): Promise<WorkflowHandle<Workflow>>
Get handle to an existing workflow
Parameters
- workflowId: string
- OptionalrunId: string
Returns Promise<WorkflowHandle<Workflow>>
- Defined in src/services/temporal-client.service.ts:179

getWorkflowResult

getWorkflowResult<T = unknown>(workflowId: string, runId?: string): Promise<T>
Wait for workflow completion and get result
Type Parameters
- T = unknown
Parameters
- workflowId: string
- OptionalrunId: string
Returns Promise<T>
- Defined in src/services/temporal-client.service.ts:315

isHealthy

isHealthy(): boolean
Check if client is available and healthy

Returns boolean
- Defined in src/services/temporal-client.service.ts:331

onModuleInit

onModuleInit(): Promise<void>
Returns Promise<void>
Implementation of OnModuleInit.onModuleInit
- Defined in src/services/temporal-client.service.ts:58

queryWorkflow

queryWorkflow<T = unknown>(
    workflowId: string,
    queryName: string,
    args?: unknown[],
    runId?: string,
): Promise<T>
Query a workflow for its current state
Type Parameters
- T = unknown
Parameters
- workflowId: string
- queryName: string
- Optionalargs: unknown[]
- OptionalrunId: string
Returns Promise<T>
- Defined in src/services/temporal-client.service.ts:274

queryWorkflowHandle

queryWorkflowHandle<T = unknown>(
    handle: WorkflowHandle,
    queryName: string,
    args?: unknown[],
): Promise<T>
Query a workflow using handle
Type Parameters
- T = unknown
Parameters
- handle: WorkflowHandle
- queryName: string
- Optionalargs: unknown[]
Returns Promise<T>
- Defined in src/services/temporal-client.service.ts:297

signalWorkflow

signalWorkflow(
    workflowId: string,
    signalName: string,
    args?: unknown[],
    runId?: string,
): Promise<void>
Send a signal to a workflow
Parameters
- workflowId: string
- signalName: string
- Optionalargs: unknown[]
- OptionalrunId: string
Returns Promise<void>
- Defined in src/services/temporal-client.service.ts:232

signalWorkflowHandle

signalWorkflowHandle(
    handle: WorkflowHandle,
    signalName: string,
    args?: unknown[],
): Promise<void>
Send a signal using workflow handle
Parameters
- handle: WorkflowHandle
- signalName: string
- Optionalargs: unknown[]
Returns Promise<void>
- Defined in src/services/temporal-client.service.ts:257

startWorkflow

startWorkflow(
    workflowType: string,
    args?: unknown[],
    options?: WorkflowStartOptions,
): Promise<WorkflowHandleWithMetadata>
Start a new workflow execution
Parameters
- workflowType: string
- args: unknown[] = []
- Optionaloptions: WorkflowStartOptions
Returns Promise<WorkflowHandleWithMetadata>
- Defined in src/services/temporal-client.service.ts:83

terminateWorkflow

terminateWorkflow(
    workflowId: string,
    reason?: string,
    runId?: string,
): Promise<void>
Terminate a workflow execution
Parameters
- workflowId: string
- Optionalreason: string
- OptionalrunId: string
Returns Promise<void>
- Defined in src/services/temporal-client.service.ts:198

Class TemporalClientService

Example

Implements

Index

Constructors

Methods

Constructors

constructor

Parameters

Returns TemporalClientService

Methods

cancelWorkflow

Parameters

Returns Promise<void>

getHealth

Returns ClientHealthStatus

getRawClient

Returns Client | null

getStatus

Returns ClientServiceStatus

getWorkflowHandle

Parameters

Returns Promise<WorkflowHandle<Workflow>>

getWorkflowResult

Type Parameters

Parameters

Returns Promise<T>

isHealthy

Returns boolean

onModuleInit

Returns Promise<void>

queryWorkflow

Type Parameters

Parameters

Returns Promise<T>

queryWorkflowHandle

Type Parameters

Parameters

Returns Promise<T>

signalWorkflow

Parameters

Returns Promise<void>

signalWorkflowHandle

Parameters

Returns Promise<void>

startWorkflow

Parameters

Returns Promise<WorkflowHandleWithMetadata>

terminateWorkflow

Parameters

Returns Promise<void>

Settings

On This Page