ManagedRaftTransport
A RaftTransport whose backing Seam can be replaced on transport tear without recreating the us.tractat.kuilt.raft.RaftNode.
The RaftNode keeps its identity and state across reconnects; only the underlying Seam is swapped when the entry server changes. This is the core primitive that makes us.tractat.kuilt.cluster.clusterClient possible.
Lifecycle
Construct with the node's stable NodeId. The transport starts with no backing Seam — peers is empty and sendTo drops frames silently until swapSeam is first called.
Pass this transport to
scope.raftNode(...)— the RaftNode lifetime is bound to scope; this transport outlives individual Seam instances.Call swapSeam with the first (and each subsequent) Seam — the RaftNode begins or resumes operation.
On transport tear: call swapSeam again with the freshly-joined Seam.
Thread safety
The current SeamRaftTransport pointer is guarded by an atomicfu reentrant lock. incoming is a hot MutableSharedFlow relayed from each seam's incoming flow; each swap launches a new relay coroutine in scope and cancels the previous one. The lock is never held across a suspend call.
Reachable peers across the swap
peers is a MutableStateFlow updated to reflect the newly installed seam's peer set on each swapSeam. Between a tear and a swap, peers holds the last known set (possibly stale).