Module heartbeat 

Structs

ElectionLeaderStepDown 🔒

HeartbeatSession 🔒

TonicHeartbeatRequestStream 🔒

Enums

LeaderStepDownEvent 🔒

Constants

MAX_NODE_EPOCH_AHEAD 🔒

How far ahead of the leader’s clock a datanode epoch can be recorded.

Traits

HeartbeatRequestStream 🔒

LeaderStepDown 🔒

Functions

accept_node_epoch 🔒

Returns whether node_epoch is not lower than the highest epoch recorded for the datanode, raising the record when it is higher. An epoch too far ahead of this metasrv’s clock is refused, since recording it would fence every later process.

get_node_id 🔒

handle_ask_leader 🔒

handle_request_stream_error 🔒

Handles request stream error by logging and forwarding the error to the client if possible.

header_only 🔒

wait_leader_step_down 🔒

Type Aliases

HeartbeatResponseResult 🔒