kuilt-session/us.tractat.kuilt.session.partition/RoundRobinEndpointSelector

RoundRobinEndpointSelector

class RoundRobinEndpointSelector(startIndex: Int = 0) : EndpointSelector

Deterministic round-robin EndpointSelector starting at startIndex.

On each next call the index advances by one modulo size. This is the default selector used by ServerClusterReconnect when none is supplied.

Parameters

startIndex

the first index returned (default 0).

Constructors

RoundRobinEndpointSelector

constructor(startIndex: Int = 0)

Functions

open override fun next(size: Int): Int

Return the index of the next endpoint to use.