The public API

The message-driven consensus server: timers, campaigns, and the tick / step surface a transport drives.

• core : Node
• id : String
• peers : Array[String]
• config : @confchange.Membership
• progress : Map[String, @tracker.Progress]
• votes : Map[String, Bool]
• mut pre_vote : Bool
• mut check_quorum : Bool
• mut in_pre_campaign : Bool
• mut leader_id : String?
• mut election_elapsed : Int
• mut heartbeat_elapsed : Int
• election_timeout : Int
• heartbeat_timeout : Int
• mut randomized_election_timeout : Int
• max_msg_bytes : UInt64
• max_uncommitted_size : UInt64
• mut uncommitted_size : UInt64
• max_inflight : Int
• max_inflight_bytes : UInt64
• mut rng : UInt64
• mut conf_applied : UInt64
• mut lead_transferee : String?
• read_only : ReadOnly
• pending_read_index : Array[(String, Bytes)]
• mut no_forward : Bool
• mut pending_conf_index : UInt64
• no_conf_change_validation : Bool
• step_down_on_removal : Bool
• pending_farewell : Array[@raftpb.Message]
• logger : &Logger
• tracer : &Tracer

• advance_applied(Self, UInt64) → Unit
• become_candidate(Self) → Unit
• become_follower(Self, UInt64) → Unit
• campaign(Self) → Array[@raftpb.Message]
• commit_index(Self) → UInt64
• conf_state(Self) → @raftpb.ConfState
• disable_proposal_forwarding(Self) → Unit
• election_deadline(Self) → Int
• enable_check_quorum(Self) → Unit
• enable_read_only_safe(Self) → Unit
• forget_leader(Self) → Unit
• from_config(Config) → Self raise ConfigError
• full_status(Self) → FullStatus
• has_lease(Self) → Bool
• id(Self) → String
• is_leader(Self) → Bool
• leader(Self) → String?
• new(String, Array[String], seed? : UInt64, election_timeout? : Int, heartbeat_timeout? : Int, max_msg_bytes? : UInt64, max_uncommitted_size? : UInt64, max_inflight? : Int, max_inflight_bytes? : UInt64, check_quorum? : Bool, pre_vote? : Bool, step_down_on_removal? : Bool, disable_conf_change_validation? : Bool, read_only_option? : ReadOnlyOption, logger? : &Logger, tracer? : &Tracer) → Self
• node(Self) → Node
• progress_of(Self, String) → ProgressStatus?
• progress_status(Self) → Array[ProgressStatus]
• promotable(Self) → Bool
• propose(Self, Bytes) → Array[@raftpb.Message]
• propose_conf(Self, @confchange.ConfChange) → Array[@raftpb.Message]
• propose_conf_v2(Self, @confchange.ConfChangeV2) → Array[@raftpb.Message]
• quorum_active(Self) → Bool
• raw(Self) → RawNode
• raw_async(Self) → RawNode
• raw_async_sized(Self, UInt64) → RawNode
• raw_with_max_committed_size(Self, UInt64) → RawNode
• read_index(Self) → UInt64?
• read_only_option(Self) → ReadOnlyOption
• reduce_uncommitted_size(Self, UInt64) → Unit
• report_snapshot(Self, String, Bool) → Unit
• report_unreachable(Self, String) → Unit
• request_read_index(Self, Bytes) → Array[@raftpb.Message]
• request_transfer_leader(Self, String) → Array[@raftpb.Message]
• role(Self) → Role
• set_pre_vote(Self, Bool) → Unit
• set_read_only_option(Self, ReadOnlyOption) → Unit
• soft_state(Self) → SoftState
• status(Self) → RaftStatus
• step(Self, @raftpb.Message) → Array[@raftpb.Message]
• take_read_states(Self) → Array[ReadState]
• term(Self) → UInt64
• tick(Self) → Array[@raftpb.Message]
• transfer_leadership(Self, String) → Array[@raftpb.Message]
• uncommitted_size(Self) → UInt64
• voter_nodes(Self) → Array[String]
• with_progress(Self, (String, ProgressStatus) -> Unit) → Unit

The synchronous Ready/Advance driver over a RaftNode — the batch a real deployment persists, sends, and applies.

• raft : RaftNode
• mut log : @log.RaftLog
• max_committed : UInt64
• msgs : Array[@raftpb.Message]
• read_states : Array[ReadState]
• mut prev_soft : SoftState
• mut prev_hard : @raftpb.HardState
• mut async_storage : Bool
• mut reflected_snap : UInt64

• advance(Self, Ready) → Unit
• apply_conf_change(Self, @confchange.ConfChange) → Array[String]
• basic_status(Self) → RaftStatus
• campaign(Self) → Unit
• conf_state(Self) → @raftpb.ConfState
• forget_leader(Self) → Unit
• full_status(Self) → FullStatus
• has_ready(Self) → Bool
• is_async(Self) → Bool
• new(RaftNode) → Self
• new_sized(RaftNode, UInt64) → Self
• next_unstable_snapshot(Self) → @raftpb.Snapshot?
• node(Self) → RaftNode
• propose(Self, Bytes) → Unit
• propose_conf(Self, @confchange.ConfChange) → Unit
• propose_conf_v2(Self, @confchange.ConfChangeV2) → Unit
• read_index(Self, Bytes) → Unit
• ready(Self) → Ready
• ready_without_accept(Self) → Ready
• report_snapshot(Self, String, Bool) → Unit
• report_unreachable(Self, String) → Unit
• stabilize(Self) → Array[@raftpb.Message]
• status(Self) → RaftStatus
• step(Self, @raftpb.Message) → Unit
• step_append_resp(Self, StorageAppendResp) → Unit
• step_apply_resp(Self, StorageApplyResp) → Unit
• store(Self, Ready) → Unit
• tick(Self) → Unit
• transfer_leader(Self, String) → Unit
• with_progress(Self, (String, ProgressStatus) -> Unit) → Unit

One batch of outstanding work: state changes, entries to persist, committed entries to apply, and messages to send.

• soft_state : SoftState?
• hard_state : @raftpb.HardState?
• read_states : Array[ReadState]
• entries : Array[@raftpb.Entry]
• snapshot : @raftpb.Snapshot?
• committed_entries : Array[@raftpb.Entry]
• messages : Array[@raftpb.Message]
• must_sync : Bool
• storage_append : StorageAppend?
• storage_apply : StorageApply?

A routed message — a sender, a recipient, and a Payload. The unit a transport moves without interpreting.

• from : String
• to : String
• payload : Payload
• force : Bool

• is_response(Self) → Bool
• kind(Self) → String
• new(String, String, Payload, force? : Bool) → Self
• term(Self) → UInt64

The deterministic, single-seed simulator: drop, delay, reorder, partition, crash — with safety-invariant checks.

• nodes : Map[String, RaftNode]
• ids : Array[String]
• mut inflight : Array[InFlight]
• mut now : Int
• part : Map[String, Int]
• down : Map[String, Bool]
• mut drop_permil : Int
• mut max_delay : Int
• mut next_group : Int
• mut rng : UInt64

• all_committed(Self, UInt64) → Bool
• committed_agrees(Self) → Bool
• compact_leader(Self, UInt64, Bytes) → Bool
• crash(Self, String) → Unit
• enable_check_quorum(Self) → Unit
• heal(Self) → Unit
• invariants_hold(Self) → Bool
• is_down(Self, String) → Bool
• isolate(Self, String) → Unit
• leader(Self) → String?
• leaders(Self) → Array[String]
• logs_consistent(Self) → Bool
• new(Array[String], seed? : UInt64) → Self
• node(Self, String) → RaftNode
• one_leader_per_term(Self) → Bool
• partition(Self, Array[String], Array[String]) → Unit
• propose(Self, Bytes) → Bool
• propose_conf(Self, @confchange.ConfChange) → Bool
• propose_on(Self, String, Bytes) → Bool
• restart(Self, String) → Unit
• run(Self, Int) → Unit
• run_until_committed(Self, UInt64, Int) → Bool
• run_until_leader(Self, Int) → String?
• same_committed_commands(Self) → Bool
• set_delay(Self, Int) → Unit
• set_drop(Self, Int) → Unit
• tick(Self) → Unit
• transfer_leadership(Self, String) → Bool

The consensus core state and role transitions the RaftNode wraps.

• id : String
• mut role : Role
• mut current_term : UInt64
• mut voted_for : String?
• log : Array[@raftpb.Entry]
• mut commit_index : UInt64
• mut last_applied : UInt64
• mut snapshot_index : UInt64
• mut snapshot_term : UInt64

• advance_commit(Self, UInt64) → Unit
• append(Self, UInt64, Bytes) → @raftpb.Entry
• append_conf(Self, UInt64, Bytes) → @raftpb.Entry
• apply_committed(Self, &StateMachine) → Unit
• apply_hard_state(Self, @raftpb.HardState) → Unit
• become_candidate(Self) → Unit
• become_follower(Self, UInt64) → Unit
• become_leader(Self) → Unit
• become_pre_candidate(Self) → Unit
• compact(Self, UInt64, Bytes, conf_state? : @raftpb.ConfState) → @raftpb.Snapshot
• current_term(Self) → UInt64
• entries_after(Self, UInt64) → Array[@raftpb.Entry]
• entries_after_limited(Self, UInt64, UInt64) → Array[@raftpb.Entry]
• entry_at(Self, UInt64) → @raftpb.Entry?
• find_conflict_by_term(Self, UInt64, UInt64) → (UInt64, UInt64)
• handle_append_entries(Self, @raftpb.AppendEntriesArgs) → @raftpb.AppendEntriesReply
• handle_install_snapshot(Self, @raftpb.InstallSnapshotArgs) → @raftpb.InstallSnapshotReply
• handle_request_vote(Self, @raftpb.RequestVoteArgs) → @raftpb.RequestVoteReply
• hard_state(Self) → @raftpb.HardState
• install_snapshot(Self, @raftpb.Snapshot) → Unit
• last_log_index(Self) → UInt64
• last_log_term(Self) → UInt64
• load_from(Self, &@storage.RaftStorage) → Unit
• log_len(Self) → Int
• mark_applied(Self, UInt64) → Unit
• new(String) → Self
• persisted(Self) → @storage.Persisted
• propose_conf_change(Self, UInt64, @confchange.ConfChange) → @raftpb.Entry
• recover(Self, @storage.Persisted) → Unit
• recover_from(Self, &@storage.WalStore) → Unit
• replay(Self, Array[@storage.WalRecord]) → Unit
• request_vote_args(Self) → @raftpb.RequestVoteArgs
• role(Self) → Role
• save_into(Self, @storage.MemoryStorage) → Unit
• save_to(Self, &@storage.WalStore) → Unit
• term_at(Self, UInt64) → UInt64

A point-in-time snapshot of a server's observable state, for monitoring and tests.

• id : String
• role : Role
• term : UInt64
• leader : String?
• commit : UInt64
• last_index : UInt64
• applied : UInt64

• describe(Self) → String

• term : UInt64
• leader_id : String
• prev_log_index : UInt64
• prev_log_term : UInt64
• entries : Array[Entry]
• leader_commit : UInt64

• term : UInt64
• success : Bool
• match_index : UInt64
• conflict_index : UInt64
• conflict_term : UInt64
• reject_index : UInt64

• mut cfg : ChangerConfig
• mut prs : Map[String, @tracker.Progress]
• mut last_index : UInt64
• max_inflight : Int
• max_inflight_bytes : UInt64

• advance_index(Self) → Unit
• conf_state(Self) → @raftpb.ConfState
• describe(Self) → String
• enter_joint(Self, Bool, Array[(String, String)]) → String?
• leave_joint(Self) → String?
• new(last_index? : UInt64, max_inflight? : Int, max_inflight_bytes? : UInt64) → Self
• restore(Self, @raftpb.ConfState) → String?
• simple(Self, Array[(String, String)]) → String?

• incoming : Array[String]
• outgoing : Array[String]
• learners : Array[String]
• learners_next : Array[String]
• mut auto_leave : Bool

• change_type : ConfChangeType
• node_id : String

• add(String) → Self
• add_learner(String) → Self
• apply_to(Self, Membership) → Unit
• decode(Bytes) → Self?
• encode(Self) → Bytes
• remove(String) → Self

• Auto
• JointImplicit
• JointExplicit

• AddNode
• RemoveNode
• AddLearnerNode

• changes : Array[ConfChange]
• transition : ConfChangeTransition

• auto(Array[ConfChange]) → Self
• auto_leave(Self) → Bool
• decode(Bytes) → Self?
• encode(Self) → Bytes
• enter_joint(Array[ConfChange], auto_leave? : Bool) → Self
• enters_joint(Self) → (Bool, Bool)
• is_leave(Self) → Bool
• leave_joint() → Self

• config : @confchange.Membership
• mut applied : UInt64

• config(Self) → @confchange.Membership
• drive(Self, Node) → Int
• new(Array[String]) → Self

• voters : Array[String]
• learners : Array[String]
• voters_outgoing : Array[String]
• learners_next : Array[String]
• auto_leave : Bool

• empty() → Self
• equivalent(Self, Self) → Bool
• is_empty(Self) → Bool

• id : String
• peers : Array[String]
• election_tick : Int
• heartbeat_tick : Int
• max_msg_bytes : UInt64
• max_uncommitted_size : UInt64
• max_inflight : Int
• max_inflight_bytes : UInt64
• check_quorum : Bool
• pre_vote : Bool
• read_only_option : ReadOnlyOption
• step_down_on_removal : Bool
• disable_proposal_forwarding : Bool
• disable_conf_change_validation : Bool
• applied : UInt64
• logger : &Logger
• tracer : &Tracer
• seed : UInt64

• new(String, Array[String], election_tick? : Int, heartbeat_tick? : Int, max_msg_bytes? : UInt64, max_uncommitted_size? : UInt64, max_inflight? : Int, max_inflight_bytes? : UInt64, check_quorum? : Bool, pre_vote? : Bool, read_only_option? : ReadOnlyOption, step_down_on_removal? : Bool, disable_proposal_forwarding? : Bool, disable_conf_change_validation? : Bool, applied? : UInt64, logger? : &Logger, tracer? : &Tracer, seed? : UInt64) → Self
• validate(Self) → Unit raise ConfigError

• seed : UInt64
• node_count : Int
• first_leader : String?
• proposal_accepted : Bool
• committed : Bool
• second_leader : String?
• one_leader_per_term : Bool
• committed_agrees : Bool
• invariants_hold : Bool

• term : UInt64
• index : UInt64
• entry_type : EntryType
• command : Bytes

• conf(UInt64, UInt64, Bytes) → Self
• id(Self) → EntryId
• is_conf_change(Self) → Bool
• normal(UInt64, UInt64, Bytes) → Self

• term : UInt64
• index : UInt64

• Normal
• ConfChange

• basic : RaftStatus
• progress : Array[ProgressStatus]
• config : @raftpb.ConfState

• term : UInt64
• vote : String?
• commit : UInt64

• initial() → Self
• is_empty(Self) → Bool

• term : UInt64
• leader_id : String
• commit : UInt64
• context : Bytes

• term : UInt64
• context : Bytes

• mut index : UInt64
• mut bytes : UInt64

• mut start : Int
• mut count : Int
• mut bytes : UInt64
• size : Int
• max_bytes : UInt64
• mut buffer : Array[Inflight]

• add(Self, UInt64, UInt64) → Unit
• clone(Self) → Self
• count(Self) → Int
• free_le(Self, UInt64) → Unit
• full(Self) → Bool
• max_bytes(Self) → UInt64
• new(Int, UInt64) → Self
• reset(Self) → Unit

• term : UInt64
• leader_id : String
• last_index : UInt64
• last_term : UInt64
• offset : UInt64
• data : Bytes
• done : Bool
• conf_state : ConfState

• whole(UInt64, String, Snapshot) → Self

• term : UInt64

• Debug
• Info
• Warning
• Error
• Fatal
• Panic

• term : UInt64
• prev : @raftpb.EntryId
• entries : Array[@raftpb.Entry]

• last_entry_id(Self) → @raftpb.EntryId
• last_index(Self) → UInt64
• valid(Self) → Bool

• members : Array[String]
• outgoing : Array[String]
• mut joint : Bool
• learners : Array[String]
• learners_next : Array[String]
• mut auto_leave : Bool

• add(Self, String) → Unit
• add_learner(Self, String) → Unit
• begin_joint(Self, Array[String]) → Unit
• committed_index(Self, Map[String, UInt64]) → UInt64
• contains(Self, String) → Bool
• enter_joint(Self, Array[String]) → Unit
• has_majority(Self, Array[String]) → Bool
• is_joint(Self) → Bool
• is_learner(Self, String) → Bool
• leave_joint(Self) → Unit
• new(Array[String]) → Self
• nodes(Self) → Array[String]
• quorum(Self) → Int
• remove(Self, String) → Unit
• size(Self) → Int
• vote_result(Self, Map[String, Bool]) → @quorum.VoteState
• voters(Self) → Array[String]

• mut hard : @raftpb.HardState
• mut snap : @raftpb.Snapshot
• mut ents : Array[@raftpb.Entry]
• mut snapshot_pending : Bool

• append(Self, Array[@raftpb.Entry]) → Unit
• apply_snapshot(Self, @raftpb.Snapshot) → Unit raise StorageError
• compact(Self, UInt64) → Unit raise StorageError
• create_snapshot(Self, UInt64, Bytes, conf_state? : @raftpb.ConfState?) → @raftpb.Snapshot raise StorageError
• from_ents(Array[@raftpb.Entry]) → Self
• new() → Self
• raw_ents(Self) → Array[@raftpb.Entry]
• seed_snapshot(Self, @raftpb.Snapshot) → Unit
• set_hard_state(Self, @raftpb.HardState) → Unit
• set_snapshot_pending(Self, Bool) → Unit
• slice(Self, UInt64, UInt64) → Array[@raftpb.Entry]

• PreVote(RequestVoteArgs)
• PreVoteResp(RequestVoteReply)
• Vote(RequestVoteArgs)
• VoteResp(RequestVoteReply)
• Append(AppendEntriesArgs)
• AppendResp(AppendEntriesReply)
• Heartbeat(HeartbeatArgs)
• HeartbeatResp(HeartbeatReply)
• Snapshot(InstallSnapshotArgs)
• TimeoutNow(UInt64)
• Propose(Array[Entry])
• ReadIndex(Bytes)
• ReadIndexResp(ReadIndexResp)
• TransferLeader(String)
• ForgetLeader

• is_local(Self) → Bool

• term : UInt64
• voted_for : String?
• log : Array[@raftpb.Entry]

• mut next_index : UInt64
• mut match_index : UInt64
• mut state : ProgressState
• mut recent_active : Bool
• mut msg_app_flow_paused : Bool
• mut pending_snapshot : UInt64
• mut is_learner : Bool
• mut sent_commit : UInt64
• inflights : Inflights

• become_probe(Self) → Unit
• become_replicate(Self) → Unit
• become_snapshot(Self, UInt64) → Unit
• can_bump_commit(Self, UInt64) → Bool
• copy(Self) → Self
• free_le(Self, UInt64) → Unit
• is_active(Self) → Bool
• is_paused(Self) → Bool
• mark_active(Self) → Unit
• maybe_decr_to(Self, UInt64, UInt64) → Bool
• maybe_decrease(Self, UInt64) → Bool
• maybe_update(Self, UInt64) → Bool
• new(UInt64, max_inflight? : Int, max_inflight_bytes? : UInt64) → Self
• note_commit_sent(Self, UInt64) → Unit
• optimistic_advance(Self, UInt64) → Unit
• reset_active(Self) → Unit
• sent_entries(Self, UInt64, Bool, bytes? : UInt64) → Unit
• to_string(Self) → String
• unpause(Self) → Unit

• Probe
• Replicate
• Snapshot

• id : String
• match_index : UInt64
• next_index : UInt64
• state : @tracker.ProgressState
• paused : Bool
• pending_snapshot : UInt64
• is_learner : Bool

• storage : &@storage.RaftStorage
• unstable : Unstable
• mut committed : UInt64
• mut applying : UInt64
• mut applied : UInt64
• max_applying_ents_size : UInt64
• mut applying_ents_size : UInt64
• mut applying_ents_paused : Bool

• accept_applying(Self, UInt64, UInt64, Bool) → Unit
• accept_unstable(Self) → Unit
• all_entries(Self) → Array[@raftpb.Entry]
• append(Self, Array[@raftpb.Entry]) → UInt64
• applied_to(Self, UInt64, UInt64) → Unit
• async_stabilize(Self, UInt64, UInt64) → Unit
• commit_stable(Self, Array[@raftpb.Entry]) → Unit
• commit_to(Self, UInt64) → Unit
• committed(Self) → UInt64
• entries(Self, UInt64, UInt64) → Array[@raftpb.Entry] raise LogCompacted
• find_conflict(Self, ArrayView[@raftpb.Entry]) → UInt64
• find_conflict_by_term(Self, UInt64, UInt64) → (UInt64, UInt64)
• first_index(Self) → UInt64
• has_next_committed_ents(Self, Bool) → Bool
• has_next_or_in_progress_unstable_ents(Self) → Bool
• has_next_unstable_ents(Self) → Bool
• has_next_unstable_snapshot(Self) → Bool
• is_up_to_date(Self, @raftpb.EntryId) → Bool
• last_entry_id(Self) → @raftpb.EntryId
• last_index(Self) → UInt64
• match_term(Self, @raftpb.EntryId) → Bool
• maybe_append(Self, LogSlice, UInt64) → UInt64?
• maybe_commit(Self, @raftpb.EntryId) → Bool
• must_check_out_of_bounds(Self, UInt64, UInt64) → Unit raise LogCompacted
• new(@storage.MemoryStorage) → Self
• new_with_size(&@storage.RaftStorage, UInt64) → Self
• next_committed_ents(Self, Bool) → Array[@raftpb.Entry]
• next_unstable_ents(Self) → Array[@raftpb.Entry]
• next_unstable_snapshot(Self) → @raftpb.Snapshot?
• pending_snapshot_index(Self) → UInt64?
• restore(Self, @raftpb.Snapshot) → Unit
• scan(Self, UInt64, UInt64, UInt64, (ArrayView[@raftpb.Entry]) -> Unit raise) → Unit raise
• seed(Self, UInt64, UInt64) → Unit
• slice(Self, UInt64, UInt64, UInt64) → Array[@raftpb.Entry] raise LogCompacted
• snapshot(Self) → @raftpb.Snapshot raise @storage.StorageError
• stable_snap_to(Self, UInt64) → Unit
• stable_to(Self, @raftpb.EntryId) → Unit
• term(Self, UInt64) → UInt64 raise @storage.StorageError
• to_string(Self) → String
• zero_term_on_out_of_bounds(Self, UInt64) → UInt64

• term : UInt64
• index : UInt64
• context : Bytes

• Safe
• LeaseBased

• index : UInt64
• request_ctx : Bytes

• term : UInt64
• candidate_id : String
• last_log_index : UInt64
• last_log_term : UInt64

• term : UInt64
• vote_granted : Bool

• Follower
• PreCandidate
• Candidate
• Leader

• last_index : UInt64
• last_term : UInt64
• data : Bytes
• conf_state : ConfState

• empty() → Self
• is_empty(Self) → Bool

• lead : String?
• state : Role

• equal(Self, Self) → Bool

• entries : Array[@raftpb.Entry]
• hard_state : @raftpb.HardState?
• snapshot : @raftpb.Snapshot?
• resp : StorageAppendResp

• index : UInt64
• log_term : UInt64
• term : UInt64

• entries : Array[@raftpb.Entry]
• resp : StorageApplyResp

• entries : Array[@raftpb.Entry]

• InitState(String)
• StateChange(String, Role, UInt64)
• Commit(String, UInt64)
• Replicate(String, Array[@raftpb.Entry])
• SendMessage(@raftpb.Message)
• ReceiveMessage(@raftpb.Message)
• ConfChange(String, @raftpb.ConfState)

• mut snapshot : @raftpb.Snapshot?
• mut entries : Array[@raftpb.Entry]
• mut offset : UInt64
• mut offset_in_progress : UInt64
• mut snapshot_in_progress : Bool

• accept_in_progress(Self) → Unit
• maybe_first_index(Self) → UInt64?
• maybe_last_index(Self) → UInt64?
• maybe_term(Self, UInt64) → UInt64?
• new(UInt64) → Self
• next_entries(Self) → Array[@raftpb.Entry]
• next_snapshot(Self) → @raftpb.Snapshot?
• restore(Self, @raftpb.Snapshot) → Unit
• slice(Self, UInt64, UInt64) → Array[@raftpb.Entry]
• stable_snap_to(Self, UInt64) → Unit
• stable_to(Self, @raftpb.EntryId) → Unit
• truncate_and_append(Self, Array[@raftpb.Entry]) → Unit

• VoteWon
• VoteLost
• VotePending

• WalHardState(@raftpb.HardState)
• WalEntry(@raftpb.Entry)
• WalSnapshot(@raftpb.Snapshot)