2022-11-14 13:54:26 +00:00
|
|
|
import { Task } from './taskbuffer.classes.task.js';
|
2022-11-09 09:36:18 +00:00
|
|
|
import * as plugins from './taskbuffer.plugins.js';
|
|
|
|
|
2022-11-14 13:54:26 +00:00
|
|
|
/**
|
2023-08-12 10:24:10 +00:00
|
|
|
* Contains all data for the final coordinator to make an informed decision.
|
2022-11-14 13:54:26 +00:00
|
|
|
*/
|
2023-01-19 13:20:44 +00:00
|
|
|
export interface IDistributedTaskRequest {
|
2023-08-12 10:24:10 +00:00
|
|
|
submitterId: string;
|
2023-08-15 09:39:31 +00:00
|
|
|
requestResponseId: string;
|
2022-11-14 13:54:26 +00:00
|
|
|
taskName: string;
|
|
|
|
taskVersion: string;
|
|
|
|
taskExecutionTime: number;
|
|
|
|
taskExecutionTimeout: number;
|
|
|
|
taskExecutionParallel: number;
|
|
|
|
status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded';
|
|
|
|
}
|
|
|
|
|
2023-01-19 13:21:36 +00:00
|
|
|
export interface IDistributedTaskRequestResult {
|
2023-08-12 10:24:10 +00:00
|
|
|
submitterId: string;
|
2023-08-15 10:02:44 +00:00
|
|
|
requestResponseId: string;
|
2022-11-14 13:54:26 +00:00
|
|
|
considered: boolean;
|
2023-08-12 10:24:10 +00:00
|
|
|
rank: number;
|
2022-11-14 13:54:26 +00:00
|
|
|
reason: string;
|
|
|
|
shouldTrigger: boolean;
|
|
|
|
}
|
|
|
|
|
2023-01-09 17:40:38 +00:00
|
|
|
export abstract class AbstractDistributedCoordinator {
|
2023-07-26 12:16:33 +00:00
|
|
|
public abstract fireDistributedTaskRequest(
|
2023-08-12 10:24:10 +00:00
|
|
|
infoBasis: IDistributedTaskRequest
|
2023-07-26 12:16:33 +00:00
|
|
|
): Promise<IDistributedTaskRequestResult>;
|
2023-08-12 10:24:10 +00:00
|
|
|
|
2023-07-26 12:16:33 +00:00
|
|
|
public abstract updateDistributedTaskRequest(
|
2023-08-12 10:24:10 +00:00
|
|
|
infoBasis: IDistributedTaskRequest
|
2023-07-26 12:16:33 +00:00
|
|
|
): Promise<void>;
|
2023-08-13 07:37:23 +00:00
|
|
|
|
|
|
|
public abstract start(): Promise<void>;
|
|
|
|
public abstract stop(): Promise<void>;
|
2023-07-26 12:16:33 +00:00
|
|
|
}
|