ChannelConfig

cc.otavia.core.config.ChannelConfig
case class ChannelConfig(connectTimeoutMs: Int = ..., writeWaterMarkLow: Int = ..., writeWaterMarkHigh: Int = ..., maxFutureInflight: Int = ..., maxStackInflight: Int = ..., maxMessagesPerRead: Int = ...)

Channel configuration defaults.

Value parameters

connectTimeoutMs

Default TCP connect timeout in milliseconds. Applied when no explicit timeout is set on the connect operation. Default is 30000ms (30 seconds).

maxFutureInflight

Maximum number of pipelined requests (ChannelFutures) that can be in-flight without waiting for responses. Enables high-performance pipelined protocols like Redis pipeline and HTTP/2 multiplexing. Default is 1.

maxMessagesPerRead

Maximum number of messages to read per read loop iteration for server channels. Controls read batching. Default is 16.

maxStackInflight

Maximum number of inbound server requests (ChannelStacks) that can be processed concurrently per channel. Default is 1.

writeWaterMarkHigh

High watermark for write buffer in bytes. When the write buffer size exceeds this threshold, the channel becomes non-writable, triggering backpressure. Default is 65536 (64KB).

writeWaterMarkLow

Low watermark for write buffer in bytes. When the write buffer size drops below this threshold after being above the high watermark, the channel becomes writable again. Default is 32768 (32KB).

Attributes

Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Inherited methods

def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product