feat: add platform manager skeleton
This commit is contained in:
@@ -5,6 +5,7 @@ import { ClusterManager } from './coreflow.classes.clustermanager.js';
|
|||||||
import { CoreflowTaskmanager } from './coreflow.classes.taskmanager.js';
|
import { CoreflowTaskmanager } from './coreflow.classes.taskmanager.js';
|
||||||
import { CoretrafficConnector } from './coreflow.connector.coretrafficconnector.js';
|
import { CoretrafficConnector } from './coreflow.connector.coretrafficconnector.js';
|
||||||
import { InternalServer } from './coreflow.classes.internalserver.js';
|
import { InternalServer } from './coreflow.classes.internalserver.js';
|
||||||
|
import { PlatformManager } from './coreflow.classes.platformmanager.js';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* the main Coreflow class
|
* the main Coreflow class
|
||||||
@@ -18,6 +19,7 @@ export class Coreflow {
|
|||||||
public cloudlyConnector: CloudlyConnector;
|
public cloudlyConnector: CloudlyConnector;
|
||||||
public corechatConnector: CoretrafficConnector;
|
public corechatConnector: CoretrafficConnector;
|
||||||
public clusterManager: ClusterManager;
|
public clusterManager: ClusterManager;
|
||||||
|
public platformManager: PlatformManager;
|
||||||
public taskManager: CoreflowTaskmanager;
|
public taskManager: CoreflowTaskmanager;
|
||||||
|
|
||||||
constructor() {
|
constructor() {
|
||||||
@@ -27,6 +29,7 @@ export class Coreflow {
|
|||||||
this.cloudlyConnector = new CloudlyConnector(this);
|
this.cloudlyConnector = new CloudlyConnector(this);
|
||||||
this.corechatConnector = new CoretrafficConnector(this);
|
this.corechatConnector = new CoretrafficConnector(this);
|
||||||
this.clusterManager = new ClusterManager(this);
|
this.clusterManager = new ClusterManager(this);
|
||||||
|
this.platformManager = new PlatformManager(this);
|
||||||
this.taskManager = new CoreflowTaskmanager(this);
|
this.taskManager = new CoreflowTaskmanager(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -59,6 +62,8 @@ export class Coreflow {
|
|||||||
console.log('cloudly connector started!');
|
console.log('cloudly connector started!');
|
||||||
await this.clusterManager.start();
|
await this.clusterManager.start();
|
||||||
console.log('cluster manager started!');
|
console.log('cluster manager started!');
|
||||||
|
await this.platformManager.start();
|
||||||
|
console.log('platform manager started!');
|
||||||
await this.taskManager.start();
|
await this.taskManager.start();
|
||||||
console.log('task manager started!');
|
console.log('task manager started!');
|
||||||
}
|
}
|
||||||
@@ -69,6 +74,7 @@ export class Coreflow {
|
|||||||
public async stop() {
|
public async stop() {
|
||||||
await this.cloudlyConnector.stop();
|
await this.cloudlyConnector.stop();
|
||||||
await this.clusterManager.stop();
|
await this.clusterManager.stop();
|
||||||
|
await this.platformManager.stop();
|
||||||
await this.taskManager.stop();
|
await this.taskManager.stop();
|
||||||
await this.internalServer.stop();
|
await this.internalServer.stop();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,22 @@
|
|||||||
|
import type { Coreflow } from './coreflow.classes.coreflow.js';
|
||||||
|
import { logger } from './coreflow.logging.js';
|
||||||
|
|
||||||
|
export class PlatformManager {
|
||||||
|
public coreflowRef: Coreflow;
|
||||||
|
|
||||||
|
constructor(coreflowRefArg: Coreflow) {
|
||||||
|
this.coreflowRef = coreflowRefArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
public async start() {
|
||||||
|
logger.log('info', 'Platform manager started');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async stop() {
|
||||||
|
logger.log('info', 'Platform manager stopped');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async reconcilePlatformServices() {
|
||||||
|
logger.log('info', 'Platform service reconciliation is not implemented yet');
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user