servers-scheduler/karya.servers.scheduler.usecases.external/FetcherService

FetcherService

class FetcherService @Inject constructor(tasksRepo: TasksRepo, config: SchedulerConfig)

Service class responsible for fetching tasks and sending them to a channel.

Constructors

Link copied to clipboard
@Inject
constructor(tasksRepo: TasksRepo, config: SchedulerConfig)

Creates an instance of FetcherService with the specified dependencies.

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun invoke(taskChannel: Channel<Task>)

Invokes the fetcher service to fetch tasks and send them to the given channel.