//clika-runtime/io.clika.runtime/ExecConfig
ExecConfig
[common]
data class ExecConfig(val batcher: BatcherConfig = BatcherConfig(), val scheduler: SchedulerConfig = SchedulerConfig(), val stream: Stream? = null, val maxQueued: Long = 0)
One executor's configuration: the batching and scheduling knobs, the stream it runs on (null = a new asynchronous stream of its own) and the in-flight cap for backpressure (0 = unbounded).
Constructors
| ExecConfig | [common] constructor(batcher: BatcherConfig = BatcherConfig(), scheduler: SchedulerConfig = SchedulerConfig(), stream: Stream? = null, maxQueued: Long = 0) |
Properties
| Name | Summary |
|---|---|
| batcher | [common] val batcher: BatcherConfig |
| maxQueued | [common] val maxQueued: Long = 0 |
| scheduler | [common] val scheduler: SchedulerConfig |
| stream | [common] val stream: Stream? = null |