class

Swim::Core

In-memory SWIM engine. Pass now from the caller so tests control time. The hot path writes packets into one buffer and does not allocate.

Constants

GC_EVERY = 60

HELPERS = 3

MAX_HEALTH = 5

PROBE_SLOTS = 64

new(local : Endpoint, *, incarnation : UInt64 = 1_u64, now : Time::Instant = Time.instant, timeout : Time::Span = 500.milliseconds, tombstone : Time::Span = 24.hours, random : Random = Random.new)

add(endpoint : Endpoint, incarnation : UInt64, status : Status, now : Time::Instant) : Nil

Adds a peer, or ignores the update when the current row wins.

alive?(endpoint : Endpoint) : Bool

each

each_deadline

expire(now : Time::Instant, & : Endpoint, Bytes -> ) : Nil

Fires due probes. A direct timeout yields ping-req packets.

get(endpoint : Endpoint) : Peer | Nil

health

incarnation

pending

receive(bytes : Bytes, now : Time::Instant, & : Endpoint, Bytes -> ) : Bool

Applies one datagram. Yields at most one reply. Returns false for a bad packet.

size

tick(now : Time::Instant, & : Endpoint, Bytes -> ) : Nil

One probe period. Yields one ping when another peer can be probed.

timeout_span