Skip to content

FailureDetector

Defined in: src/cluster/FailureDetector.ts:32

A simple, deterministic failure detector. Every heartbeat bumps the last-seen timestamp for a peer; the cluster periodically asks which peers have fallen past the thresholds. No φ-accrual / variance tracking — just plain elapsed-time limits, which is sufficient for LAN-scale clusters.

new FailureDetector(settings?): FailureDetector

Defined in: src/cluster/FailureDetector.ts:35

FailureDetectorSettings = defaultFailureDetectorSettings

FailureDetector

get interval(): number

Defined in: src/cluster/FailureDetector.ts:67

number

decide(peer, now?): FailureDecision

Defined in: src/cluster/FailureDetector.ts:54

NodeAddress

number = ...

FailureDecision


forget(peer): void

Defined in: src/cluster/FailureDetector.ts:50

NodeAddress

void


heartbeat(peer, now?): void

Defined in: src/cluster/FailureDetector.ts:38

Record that a message was received from peer (any message counts).

NodeAddress

number = ...

void


lastSeen(peer): Option<number>

Defined in: src/cluster/FailureDetector.ts:63

NodeAddress

Option<number>


register(peer, now?): void

Defined in: src/cluster/FailureDetector.ts:45

Record that we know about a peer even if we haven’t heard from it yet.

NodeAddress

number = ...

void