/// /// declare module "copyright" { export class WorkerLogicGlobalCopyright { static toString(): string; } } declare module "sk/worker/logic/global/IndexSpace" { export class IndexSpace { static namespaces(): string[]; } } declare module "sk/worker/logic/global/WorkerAliveService" { import { InvokeThread } from 'cross/runtime/module/thread/InvokeThread'; import { ThreadService } from 'cross/runtime/module/thread/ThreadService'; import { Service } from 'cross/runtime/module/Service'; import { StatisticsTrackDeclare } from 'foundation/core/module/statistics/StatisticsTrackDeclare'; import { StatisticsTracStageDeclare } from 'foundation/core/module/statistics/StatisticsTracStageDeclare'; export class DesignApllicationTrackEnum { static Stage: StatisticsTracStageDeclare; static Fatal: StatisticsTrackDeclare; } type ClientStatusInfo = { id: string; status: string; lastHeartBeat: number; }; export class WorkerAliveService extends Service { clients: Map; protected _thread: InvokeThread; protected _deadTime: number; protected _threadService: ThreadService; constructor(); onActive(): void; onDeactive(): void; start(clientId: string): void; stop(clientId: string): void; pause(clientId: string): void; resume(clientId: string): void; heartBeat(clientId: string): void; crashCheck(): void; } } declare module "sk/worker/logic/global/WorkerCommonAliveRequestProcessor" { import { BaseObject } from 'cross/runtime/lang/BaseObject'; import { IContext } from 'cross/runtime/lang/IContext'; import { ResultObject } from 'cross/runtime/lang/ResultObject'; import { IWorkerMessageProcessor } from 'foundation/core/module/worker/IWorkerMessageProcessor'; import { WorkerCommonAliveRequest } from 'sk/data/logic/digitization/message/WorkerCommonAliveRequest'; import { WorkerCommonAliveResponse } from 'sk/data/logic/digitization/message/WorkerCommonAliveResponse'; import { WorkerAliveService } from "sk/worker/logic/global/WorkerAliveService"; export class WorkerCommonAliveRequestProcessor extends BaseObject implements IWorkerMessageProcessor { protected _workerAliveService: WorkerAliveService; processAsync(context: IContext, request: WorkerCommonAliveRequest): Promise>; } }