Kafunk


ChanConfig

Namespace: Kafunk

Configuration for a TCP channel to an individual broker.

Record Fields

Record FieldDescription
bufferPool
Signature: IBufferPool

The buffer pool to use for requests.

connectRetryPolicy
Signature: RetryPolicy

The connection retry policy for timeouts and failures.

connectTimeout
Signature: TimeSpan

The connection timeout.

receiveBufferSize
Signature: int

The socket receive buffer size.

requestRetryPolicy
Signature: RetryPolicy

The request retry polify for timeouts and failures.

requestTimeout
Signature: TimeSpan

The request timeout.

sendBufferSize
Signature: int

The socket send buffer size.

useNagle
Signature: bool

Specifies whether the socket should use Nagle's algorithm.

Static members

Static memberDescription
create(...)
Signature: (useNagle:bool option * receiveBufferSize:int option * sendBufferSize:int option * connectTimeout:TimeSpan option * connectRetryPolicy:RetryPolicy option * requestTimeout:TimeSpan option * requestRetryPolicy:RetryPolicy option * bufferPool:IBufferPool option) -> ChanConfig

Creates a broker TCP channel configuration.

DefaultBufferPool
Signature: IBufferPool

The default buffer pool = BufferPool.GC.

CompiledName: get_DefaultBufferPool

DefaultConnectRetryPolicy
Signature: RetryPolicy

The default TCP connection retry policy = RetryPolicy.expRandLimitBoundedMs 50 1.5 0.2 1000 2.

CompiledName: get_DefaultConnectRetryPolicy

DefaultConnectTimeout
Signature: TimeSpan

The default TCP connection timeout = 10s.

CompiledName: get_DefaultConnectTimeout

DefaultReceiveBufferSize
Signature: int

The default TCP receive buffer size = 65536.

CompiledName: get_DefaultReceiveBufferSize

DefaultRequestRetryPolicy
Signature: RetryPolicy

The default TCP request retry policy = RetryPolicy.expRandLimitBoundedMs 100 1.5 0.2 1000 2.

CompiledName: get_DefaultRequestRetryPolicy

DefaultRequestTimeout
Signature: TimeSpan

The default TCP request timeout = 30s.

CompiledName: get_DefaultRequestTimeout

DefaultSendBufferSize
Signature: int

The default TCP send buffer size = 65536.

CompiledName: get_DefaultSendBufferSize

DefaultUseNagle
Signature: bool

The default TCP Nagle setting = false.

CompiledName: get_DefaultUseNagle

Fork me on GitHub