From 964ddac31baddd63021574c3b9b7ebeb0e708e2d Mon Sep 17 00:00:00 2001 From: Rajon Ahmed Date: Fri, 28 Aug 2026 12:47:10 +0800 Subject: [PATCH] upd: essential/file updated worker manager updated --- .../hidden/service/worker/manager/manager.go | 57 +++++++++++++++++++ 1 file changed, 57 insertions(+) diff --git a/essential/hidden/service/worker/manager/manager.go b/essential/hidden/service/worker/manager/manager.go index e69de29..7f9814a 100644 --- a/essential/hidden/service/worker/manager/manager.go +++ b/essential/hidden/service/worker/manager/manager.go @@ -0,0 +1,57 @@ +/* +|-------------------------------------------------------------------------- +| Description +|-------------------------------------------------------------------------- +| +| Name: +| - Manager +| +| Purpose: +| - Provides the clock synchronization service for maintaining a +| consistent system time reference across automation tasks. +| +|-------------------------------------------------------------------------- +*/ + +/* +|-------------------------------------------------------------------------- +| Credit +|-------------------------------------------------------------------------- +| +| Contributor: +| - Rajon Ahmed +| - Blockonite +| +|-------------------------------------------------------------------------- +*/ + +package manager + +import ( + "go/module/essential/hidden/service/worker/clock" + // Import more workers as needed. +) + +// ObrimWorkerManagerAction defines a worker manager action. +type ObrimWorkerManagerAction string + +const ( + // ObrimWorkerManagerActionStart starts all framework workers. + ObrimWorkerManagerActionStart ObrimWorkerManagerAction = "start" + + // ObrimWorkerManagerActionStop stops all framework workers. + ObrimWorkerManagerActionStop ObrimWorkerManagerAction = "stop" +) + +// ObrimWorkerManager starts or stops all framework workers. +func ObrimWorkerManager(action ObrimWorkerManagerAction) { + switch action { + case ObrimWorkerManagerActionStart: + clock.ObrimClockStart() + // Add more worker start functions as needed. + + case ObrimWorkerManagerActionStop: + clock.ObrimClockStop() + // Add more worker stop functions as needed. + } +}