Skip to main content

Class: TemporalDiscoveryService

Defined in: src/services/temporal-discovery.service.ts:31

Temporal Discovery Service

Automatically discovers and manages Temporal components including:

  • Activities with

Activity​

decorator

  • Signals with

Signal Method​

decorator

  • Queries with

Query Method​

decorator

  • Child workflows with

Child Workflow​

decorator

Provides introspection and statistics about discovered components.

Implements​

  • OnModuleInit

Constructors​

Constructor​

new TemporalDiscoveryService(discoveryService, metadataAccessor?, options, activityModuleOptions?): TemporalDiscoveryService

Defined in: src/services/temporal-discovery.service.ts:39

Parameters​

discoveryService​

DiscoveryService

metadataAccessor?​

TemporalMetadataAccessor = ...

options​

TemporalOptions

activityModuleOptions?​

ActivityModuleOptions = ...

Returns​

TemporalDiscoveryService

Methods​

executeActivity()​

executeActivity(name, ...args): Promise<ActivityExecutionResult<unknown>>

Defined in: src/services/temporal-discovery.service.ts:119

Execute an activity by name

Parameters​

name​

string

args​

...unknown[]

Returns​

Promise<ActivityExecutionResult<unknown>>

getActivity()​

getActivity(name): ActivityMethodHandler | undefined

Defined in: src/services/temporal-discovery.service.ts:79

Get activity by name

Parameters​

name​

string

Returns​

ActivityMethodHandler | undefined

getActivityNames()​

getActivityNames(): string[]

Defined in: src/services/temporal-discovery.service.ts:112

Get activity names

Returns​

string[]

getAllActivities()​

getAllActivities(): Record<string, ActivityMethodHandler>

Defined in: src/services/temporal-discovery.service.ts:90

Get all registered activities as handlers map

Returns​

Record<string, ActivityMethodHandler>

getDiscoveredActivities()​

getDiscoveredActivities(): Map<string, DiscoveredActivity>

Defined in: src/services/temporal-discovery.service.ts:72

Get all discovered activities

Returns​

Map<string, DiscoveredActivity>

getHealthStatus()​

getHealthStatus(): DiscoveryHealthStatus

Defined in: src/services/temporal-discovery.service.ts:183

Get health status for monitoring

Returns​

DiscoveryHealthStatus

getStats()​

getStats(): DiscoveryServiceStats

Defined in: src/services/temporal-discovery.service.ts:172

Get discovery statistics

Returns​

DiscoveryServiceStats

hasActivity()​

hasActivity(name): boolean

Defined in: src/services/temporal-discovery.service.ts:105

Check if an activity exists

Parameters​

name​

string

Returns​

boolean

onModuleInit()​

onModuleInit(): Promise<void>

Defined in: src/services/temporal-discovery.service.ts:55

Returns​

Promise<void>

Implementation of​

OnModuleInit.onModuleInit

rediscover()​

rediscover(): Promise<ComponentDiscoveryResult>

Defined in: src/services/temporal-discovery.service.ts:159

Refresh/rediscover components

Returns​

Promise<ComponentDiscoveryResult>