SchedulerWorker

class SchedulerWorker @Inject constructor(workerService: WorkerService, repoConnector: RepoConnector, locksClient: LocksClient, queueClient: ProducerQueueClient)

Scheduler worker responsible for starting and stopping the task processing.

Constructors

@Inject

constructor(workerService: WorkerService, repoConnector: RepoConnector, locksClient: LocksClient, queueClient: ProducerQueueClient)

Creates an instance of SchedulerWorker with the specified dependencies.

object Companion : Logging

suspend fun start(instanceId: Int, channel: ReceiveChannel<Task>)

Starts the worker service to begin processing tasks.

suspend fun stop(instanceId: Int)

Stops the worker service and shuts down the repository connector, locks client, and queue client.