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

Package-level declarations

Types

class DefaultJoinerReconnectController(roomId: RoomId, reconnectWindowMs: Long = DEFAULT_RECONNECT_WINDOW_MS, clock: () -> Long, scope: CoroutineScope) : JoinerReconnectController

Default implementation of JoinerReconnectController.

EndpointSelector

fun interface EndpointSelector

Strategy that picks the next endpoint index from a cluster list on each call.

JoinerReconnectController

interface JoinerReconnectController

Manages per-peer reconnect windows on the leader side.

JoinerReconnectEvent

sealed interface JoinerReconnectEvent

Events emitted by JoinerReconnectController over its SharedFlow.

ResumeResult

sealed interface ResumeResult

How a resume attempt turned out — on either side of the protocol.

ResumeToken

data class ResumeToken(val peerId: PeerId, val roomId: RoomId, val issuedAt: Long)

Opaque token a joiner presents when reconnecting after a transport drop.

RoomId

@JvmInline

value class RoomId(val value: String)

Stable handle for a P2P Room session. Survives leader changes: the RoomId is assigned at Room creation and does not rotate if auto-election promotes a new leader.

RoundRobinEndpointSelector

class RoundRobinEndpointSelector(startIndex: Int = 0) : EndpointSelector

Deterministic round-robin EndpointSelector starting at startIndex.

ServerClusterReconnect

class ServerClusterReconnect(endpoints: List<Tag>, selector: EndpointSelector = RoundRobinEndpointSelector(startIndex = 0))

Reconnect helper for a joiner that faces a static cluster of server endpoints.