From 9cce79f0400e62fe436105321a45fb1f6a6cddde Mon Sep 17 00:00:00 2001 From: Juergen Kunz Date: Tue, 28 Apr 2026 11:18:15 +0000 Subject: [PATCH] feat: add platform manager skeleton --- ts/coreflow.classes.coreflow.ts | 6 ++++++ ts/coreflow.classes.platformmanager.ts | 22 ++++++++++++++++++++++ 2 files changed, 28 insertions(+) create mode 100644 ts/coreflow.classes.platformmanager.ts diff --git a/ts/coreflow.classes.coreflow.ts b/ts/coreflow.classes.coreflow.ts index 5bd8d2e..b782be8 100644 --- a/ts/coreflow.classes.coreflow.ts +++ b/ts/coreflow.classes.coreflow.ts @@ -5,6 +5,7 @@ import { ClusterManager } from './coreflow.classes.clustermanager.js'; import { CoreflowTaskmanager } from './coreflow.classes.taskmanager.js'; import { CoretrafficConnector } from './coreflow.connector.coretrafficconnector.js'; import { InternalServer } from './coreflow.classes.internalserver.js'; +import { PlatformManager } from './coreflow.classes.platformmanager.js'; /** * the main Coreflow class @@ -18,6 +19,7 @@ export class Coreflow { public cloudlyConnector: CloudlyConnector; public corechatConnector: CoretrafficConnector; public clusterManager: ClusterManager; + public platformManager: PlatformManager; public taskManager: CoreflowTaskmanager; constructor() { @@ -27,6 +29,7 @@ export class Coreflow { this.cloudlyConnector = new CloudlyConnector(this); this.corechatConnector = new CoretrafficConnector(this); this.clusterManager = new ClusterManager(this); + this.platformManager = new PlatformManager(this); this.taskManager = new CoreflowTaskmanager(this); } @@ -59,6 +62,8 @@ export class Coreflow { console.log('cloudly connector started!'); await this.clusterManager.start(); console.log('cluster manager started!'); + await this.platformManager.start(); + console.log('platform manager started!'); await this.taskManager.start(); console.log('task manager started!'); } @@ -69,6 +74,7 @@ export class Coreflow { public async stop() { await this.cloudlyConnector.stop(); await this.clusterManager.stop(); + await this.platformManager.stop(); await this.taskManager.stop(); await this.internalServer.stop(); } diff --git a/ts/coreflow.classes.platformmanager.ts b/ts/coreflow.classes.platformmanager.ts new file mode 100644 index 0000000..9d1b1dc --- /dev/null +++ b/ts/coreflow.classes.platformmanager.ts @@ -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'); + } +}