raft_fleet v0.10.2

RaftFleet.ProcessAndDiskLogIndexInspector (raft_fleet v0.10.2) View Source

A GenServer that reports "eligibility" of a node for hosting the 1st member of a new consensus group.

When starting a new consensus group, a manager process collects reports from all active nodes and determine where to spawn the 1st member process. The report includes:

  • whether there exists a process whose registered name equals to the consensus group name
  • last log index in locally stored files (if any)

Link to this section Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

find_node_having_latest_log_index(name)
init(atom)

Callback implementation for GenServer.init/1.

start_link(arg0)

Link to this section Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

find_node_having_latest_log_index(name)

View Source

Specs

find_node_having_latest_log_index(atom()) ::
  {:ok, nil | node()} | {:error, :process_exists}
Link to this function

init(atom)

View Source

Callback implementation for GenServer.init/1.

Link to this function

start_link(arg0)

View Source

Specs

start_link([]) :: {:ok, pid()}