///
///
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>;
}
}