servers-scheduler/karya.servers.scheduler.usecases/SchedulerFetcher

SchedulerFetcher

class SchedulerFetcher @Inject constructor(fetcherService: FetcherService, repoConnector: RepoConnector, config: SchedulerConfig)

Scheduler fetcher responsible for starting and stopping the task fetching process.

Constructors

SchedulerFetcher

@Inject

constructor(fetcherService: FetcherService, repoConnector: RepoConnector, config: SchedulerConfig)

Creates an instance of SchedulerFetcher with the specified dependencies.

Types

object Companion : Logging

Properties

taskReadChannel

val taskReadChannel: ReceiveChannel<Task>

Provides a receive-only channel for consumers to read tasks.

Functions

suspend fun start()

Starts the fetcher service to begin fetching tasks.

suspend fun stop()

Stops the fetcher service and shuts down the repository connector.