status-im/nim-raft
2
0
Fork 0
mirror of https://github.com/status-im/nim-raft.git synced 2025-02-12 04:56:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix typo and compile error

Browse Source
This commit is contained in:
Raycho Mukelov 2023-08-06 06:27:34 +03:00
parent ba23c8bb62
commit 1859b20ed5
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
raft_consensus/raft_consensus_api.nim
View File

@ -9,7 +9,7 @@
import types import types
import protocol import protocol
import stew # import stew
export types, protocol export types, protocol
@ -53,7 +53,7 @@ proc RAFTNodeRequest*(node: RAFTNode, req: RAFTNodeClientRequest): RAFTNodeClien
proc RAFTNodeLogLenGet*(node: RAFTNode): RAFTLogIndex = proc RAFTNodeLogLenGet*(node: RAFTNode): RAFTLogIndex =
discard discard
proc RAFTNodeLogentryGet*(node: RAFTLogIndex): Result[RAFTNodeLogEntry, string] = proc RAFTNodeLogEntryGet*(node: RAFTLogIndex): Result[RAFTNodeLogEntry, string] =
discard discard
proc RAFTNodeStateMachineStateGet*(node: RAFTNode): RAFTNodeStateMachineState = proc RAFTNodeStateMachineStateGet*(node: RAFTNode): RAFTNodeStateMachineState =

10
raft_consensus/types.nim
View File

@ -27,7 +27,7 @@ type
RAFTLogIndex* = uint64 # RAFT Node Log Index Type RAFTLogIndex* = uint64 # RAFT Node Log Index Type
# RAFT Node State Machine basic definitions # RAFT Node State Machine basic definitions
mixin RAFTNodeStateMachineState* = object # State Machine State RAFTNodeStateMachineState* = object # State Machine State
RAFTNodeStateMachine* = ref object # Some probably opaque State Machine Impelementation to be used by the RAFT Node RAFTNodeStateMachine* = ref object # Some probably opaque State Machine Impelementation to be used by the RAFT Node
# providing at minimum operations for initialization, querying the current state # providing at minimum operations for initialization, querying the current state
# and RAFTNodeLogEntry application # and RAFTNodeLogEntry application
@ -44,7 +44,7 @@ type
RAFTLogCompactionModule* = object of RootObj RAFTLogCompactionModule* = object of RootObj
raft_node_access_callback: RAFTNodeAccessCallback raft_node_access_callback: RAFTNodeAccessCallback
RAFTMembershipChangeModule* = object of RootObj RAFTMembershipChangeModule* = object of RootObj
raft_node_access_callback: RAFTNodeAccessCallback raft_node_access_callback: RAFTNodeAccessCallback
@ -63,7 +63,7 @@ type
RAFTNodeLog* = ref object # Needs more elaborate definition. Probably this will be a RocksDB/MDBX/SQLite Store Wrapper etc. RAFTNodeLog* = ref object # Needs more elaborate definition. Probably this will be a RocksDB/MDBX/SQLite Store Wrapper etc.
log_data*: seq[RAFTNodeLogEntry] # RAFT Node Log Data log_data*: seq[RAFTNodeLogEntry] # RAFT Node Log Data
# Base typoe for RAFT message objects # Base typoe for RAFT message objects
RAFTMessageBase* = ref object of RootObj # Base Type for RAFT Node Messages RAFTMessageBase* = ref object of RootObj # Base Type for RAFT Node Messages
msg_id*: RAFTMessageId # Message UUID msg_id*: RAFTMessageId # Message UUID
@ -103,12 +103,12 @@ type
# makes sense for the moment # makes sense for the moment
state_machine: RAFTNodeStateMachine # Not sure for now putting it here. I assume that persisting the State Machine's state is enough state_machine: RAFTNodeStateMachine # Not sure for now putting it here. I assume that persisting the State Machine's state is enough
# to consider it 'persisted' # to consider it 'persisted'
# Volatile state # Volatile state
commit_index: RAFTLogIndex # Index of highest log entry known to be committed (initialized to 0, increases monotonically) commit_index: RAFTLogIndex # Index of highest log entry known to be committed (initialized to 0, increases monotonically)
last_applied: RAFTLogIndex # Index of highest log entry applied to state machine (initialized to 0, increases monotonically) last_applied: RAFTLogIndex # Index of highest log entry applied to state machine (initialized to 0, increases monotonically)
current_leader_id: RAFTNodeId # Current RAFT Node Leader ID (used to redirect Client Requests in case this RAFT Node is not the leader) current_leader_id: RAFTNodeId # Current RAFT Node Leader ID (used to redirect Client Requests in case this RAFT Node is not the leader)
# Volatile state on leaders # Volatile state on leaders
next_index: seq[RAFTLogIndex] # For each peer RAFT Node, index of the next log entry to send to that Node next_index: seq[RAFTLogIndex] # For each peer RAFT Node, index of the next log entry to send to that Node
# (initialized to leader last log index + 1) # (initialized to leader last log index + 1)