servers-scheduler/karya.servers.scheduler.configs/SchedulerConfig

SchedulerConfig

data class SchedulerConfig(val threadCount: Int, val workers: Int, val channelCapacity: Int, val pollFrequency: Long, val partitions: List<Int>, val executionBufferInMilli: Long, val metricsEnabled: Boolean, val repoConfig: RepoConfig, val locksConfig: LocksConfig, val queueConfig: QueueConfig)

Configuration class for the scheduler.

Constructors

SchedulerConfig

constructor(threadCount: Int, workers: Int, channelCapacity: Int, pollFrequency: Long, partitions: List<Int>, executionBufferInMilli: Long, metricsEnabled: Boolean, repoConfig: RepoConfig, locksConfig: LocksConfig, queueConfig: QueueConfig)

Types

object Companion

Properties

channelCapacity

val channelCapacity: Int

The capacity of the task channel.

executionBufferInMilli

val executionBufferInMilli: Long

The buffer time in milliseconds while fetching a task to be executed.

val locksConfig: LocksConfig

The configuration for the locks.

val metricsEnabled: Boolean

Whether metrics are enabled.

val partitions: List<Int>

The list of partitions from which to poll from.

val pollFrequency: Long

The frequency at which tasks are polled.

val queueConfig: QueueConfig

The configuration for the queue.

val repoConfig: RepoConfig

The configuration for the repository.

val threadCount: Int

The number of threads to be used by the scheduler.

val workers: Int

The number of worker instances.