Raft::Message
Constants
PROTOCOL_VERSION = 1_u8
Constructors
from_io(io : IO, max_payload : UInt32, format : IO::ByteFormat = IO::ByteFormat::LittleEndian) : self
Sourcenew(protocol_version : UInt8 = PROTOCOL_VERSION, group_id : UInt64 = 0_u64, type : MessageType = MessageType::AppendEntries, from : NodeID = 0_u64, term : UInt64 = 0_u64, prev_log_index : UInt64 = 0_u64, prev_log_term : UInt64 = 0_u64, commit_index : UInt64 = 0_u64, last_log_index : UInt64 = 0_u64, last_log_term : UInt64 = 0_u64, success : Bool = false, reject_hint : UInt64 = 0_u64, entries_data : Bytes = Bytes.new(0), entries_count : UInt32 = 0_u32)
SourceInstance methods
commit_index
Sourceentries_count
Sourceentries_data
Sourcefrom
Sourcefrom=(from : NodeID)
Sourcegroup_id
Sourcelast_log_index
Sourcelast_log_term
Sourceprev_log_index
Sourceprev_log_term
Sourceprotocol_version
Sourcereject_hint
Sourcesuccess
Sourceterm
Sourcetype
Sourcetype=(type : MessageType)
Source