1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
import { IActivitySpec } from "./types";
import { Service } from "./service";
import { Subscription } from "./subscription";
export interface ICreateDummyCallback {
activity: { name: string };
isDummyActivity: boolean;
}
export declare class ActivityManager {
public constructor(service: Service, idleTimeout: number);
public readonly idleTimeout: number;
public readonly service: Service;
public exitOnTimeout: boolean;
public useDummyActivity: boolean;
private readonly _activities: { [id: string]: Subscription };
private _counter: number;
private _dummyActivityId: number;
private _idleTimer: NodeJS.Timeout | null;
public adopt(activity: Record<string, any>, callback?: (payload: Record<string, any>) => void): void;
public complete(activity: Record<string, any>, options?: Record<string, any>, callback?: (payload: Record<string, any>) => void): boolean | void;
public create(spec: string | Record<string, any>, callback: (payload: any) => void): void;
private _add(id: string, activity: Subscription): void;
private _createActual(activitySpec: IActivitySpec, callback?: (payload: any) => void): void;
private _createDummy(jobId: string, callback?: (payload: ICreateDummyCallback) => void): void;
private _createInternal(jobId: string, callback?: (payload: any) => void): void;
private _remove(id: string): void;
private _startTimer(): void;
private _stopTimer(): void;
}
|
