import { OnModuleInit, OnModuleDestroy } from '@nestjs/common'; import { TemporalOptions, WorkflowStartOptions, ServiceHealth, WorkerStatus, ActivityMethodInfo, MetadataInfo, TemporalServiceInitResult, WorkflowExecutionResult, WorkflowSignalResult, WorkflowQueryResult, WorkflowTerminationResult, WorkflowCancellationResult, ActivityExecutionResult, OverallHealthStatus, ServiceStatistics, WorkerDefinition, MultipleWorkersInfo, CreateWorkerResult, Worker } from '../interfaces'; import { TemporalClientService } from './temporal-client.service'; import { TemporalWorkerManagerService } from './temporal-worker.service'; import { TemporalScheduleService } from './temporal-schedule.service'; import { TemporalDiscoveryService } from './temporal-discovery.service'; import { TemporalMetadataAccessor } from './temporal-metadata.service'; export declare class TemporalService implements OnModuleInit, OnModuleDestroy { private readonly options; private readonly clientService; private readonly workerService; private readonly scheduleService; private readonly discoveryService; private readonly metadataAccessor; private readonly logger; private isInitialized; private shutdownPromise; constructor(options: TemporalOptions, clientService: TemporalClientService, workerService: TemporalWorkerManagerService, scheduleService: TemporalScheduleService, discoveryService: TemporalDiscoveryService, metadataAccessor: TemporalMetadataAccessor); onModuleInit(): Promise; onModuleDestroy(): Promise; private waitForServicesInitialization; private performShutdown; startWorkflow(workflowType: string, args?: unknown[], options?: WorkflowStartOptions): Promise>; signalWorkflow(workflowId: string, signalName: string, args?: unknown[]): Promise; signalWithStart(workflowType: string, signalName: string, signalArgs: unknown[], workflowArgs: unknown[], options?: WorkflowStartOptions): Promise; queryWorkflow(workflowId: string, queryName: string, args?: unknown[]): Promise>; getWorkflowHandle(workflowId: string, runId?: string): Promise; terminateWorkflow(workflowId: string, reason?: string): Promise; cancelWorkflow(workflowId: string): Promise; startWorker(): Promise; stopWorker(): Promise; isWorkerRunning(): boolean; hasWorker(): boolean; getWorkerStatus(): WorkerStatus | null; getWorkerManager(): TemporalWorkerManagerService; getWorker(taskQueue: string): Worker | null; getAllWorkers(): MultipleWorkersInfo | null; getWorkerStatusByTaskQueue(taskQueue: string): WorkerStatus | null; startWorkerByTaskQueue(taskQueue: string): Promise; stopWorkerByTaskQueue(taskQueue: string): Promise; registerWorker(workerDef: WorkerDefinition): Promise; executeActivity(name: string, ...args: unknown[]): Promise>; getActivity(name: string): Function | undefined; getAllActivities(): Record; hasActivity(name: string): boolean; getActivityNames(): string[]; isActivity(target: Function): boolean; isActivityMethod(target: object, methodName: string): boolean; getActivityMetadata(target: Function): MetadataInfo | null; extractActivityMethods(target: Function): ActivityMethodInfo[]; getOverallHealth(): Promise; getWorkerHealth(): Promise<{ status: 'healthy' | 'unhealthy' | 'degraded' | 'not_available'; details?: WorkerStatus; }>; getHealth(): { status: 'healthy' | 'unhealthy' | 'degraded'; services: { client: ServiceHealth; worker: ServiceHealth; schedule: ServiceHealth; activity: ServiceHealth; discovery: ServiceHealth; }; isInitialized: boolean; namespace: string; summary: { totalActivities: number; totalSchedules: number; workerRunning: boolean; clientConnected: boolean; }; }; getStats(): ServiceStatistics; private logServiceStatus; private ensureInitialized; private enhanceWorkflowOptions; private getClientHealth; private getWorkerHealthStatus; private getScheduleHealth; private getActivityHealth; private getDiscoveryHealth; private getActivityCount; private getScheduleCount; get client(): TemporalClientService; get worker(): TemporalWorkerManagerService; get schedule(): TemporalScheduleService; get activity(): TemporalDiscoveryService; get discovery(): TemporalDiscoveryService; get metadata(): TemporalMetadataAccessor; private extractErrorMessage; }