Code

WIP: Add raft example#153

Code

Open

Elbehery wants to merge 33 commits intoetcd-io:mainetcd-io/raft:mainfrom Elbehery:add_raft_exampleElbehery/raft:add_raft_exampleCopy head branch name to clipboard

+1,612

Commits

Commits on Feb 21, 2024

• Add a Linux implementation of file locking

  Show description for 247f961
  

  mhagger

  authored and

  Elbehery

  committed
  247f961

• Fix/suppress some linter warnings

  Show description for e2141f7
  

  mhagger

  authored and

  Elbehery

  committed
  e2141f7

• Define SnapshotStorage interface

  Show description for 7b97b3a
  

  mhagger

  authored and

  Elbehery

  committed
  7b97b3a

• Define KVStore interface

  Show description for 84b03dc
  

  mhagger

  authored and

  Elbehery

  committed
  84b03dc

• raftNode: initialize snapshotStorage in newRaftNode()

  Show description for cdd60c2
  

  mhagger

  authored and

  Elbehery

  committed
  cdd60c2

• newRaftNode(): inline part of the goroutine's work

  Show description for 5034ccf
  

  mhagger

  authored and

  Elbehery

  committed
  5034ccf

• startRaftNode(): replacement for newRaftNode()

  Show description for c1dd4dc
  

  mhagger

  authored and

  Elbehery

  committed
  c1dd4dc

• raftNode.snapdir: remove member

  Show description for 2a547ec
  

  mhagger

  authored and

  Elbehery

  committed
  2a547ec

• raftNode.id: convert type to uint64

  Show description for 0fdf48b
  

  mhagger

  authored and

  Elbehery

  committed
  0fdf48b

• startRaftNode(): take the SnapshotStorage as an argument

  Show description for 17981fa
  

  mhagger

  authored and

  Elbehery

  committed
  17981fa

• kvstore.loadAndApplySnapshot(), applyCommits(): extract methods

  Show description for 34654f2
  

  mhagger

  authored and

  Elbehery

  committed
  34654f2

• kvstore: separate initialization from startup

  Show description for 5be8540
  

  mhagger

  authored and

  Elbehery

  committed
  5be8540

• kvstore.loadSnapshot(): inline method

  Show description for 302d8a5
  

  mhagger

  authored and

  Elbehery

  committed
  302d8a5

• FSM: new interface, representing a finite state machine

  Show description for 78c9106
  

  mhagger

  authored and

  Elbehery

  committed
  78c9106

• Move more functionality from kvstore to kvfsm

  Show description for 9163a7d
  

  mhagger

  authored and

  Elbehery

  committed
  9163a7d

• TestProposeOnCommit(): add some clarifying comments

  Show description for 2ea3a54
  

  mhagger

  authored and

  Elbehery

  committed
  2ea3a54

• raftexample_test: introduce peer type

  Show description for a328306
  

  mhagger

  authored and

  Elbehery

  committed
  a328306

• raftexample_test: give each peer its own FSM

  Show description for 7b9b2cc
  

  mhagger

  authored and

  Elbehery

  committed
  7b9b2cc

• kvfsm.applyCommits(): return an error

  Show description for 1de94b9
  

  mhagger

  authored and

  Elbehery

  committed
  1de94b9

• FSM.ProcessCommits(): return an error rather than calling log.Fatal()

  Show description for b44de5b
  

  mhagger

  authored and

  Elbehery

  committed
  b44de5b

• FSM.ApplyCommits(): new method

  Show description for 58d3994
  

  mhagger

  authored and

  Elbehery

  committed
  58d3994

• newKVStore(): don't call LoadAndApplySnapshot()

  Show description for 4feda00
  

  mhagger

  authored and

  Elbehery

  committed
  4feda00

• Make ProcessCommits() a method of raftNode

  Show description for ba8d8ca
  

  mhagger

  authored and

  Elbehery

  committed
  ba8d8ca

• newRaftNode(): call LoadAndApplySnapshot() here

  Show description for bb3c651
  

  mhagger

  authored and

  Elbehery

  committed
  bb3c651

• LoadAndApplySnapshot(): move method to raftNode and make it private

  Show description for 73ae94b
  

  mhagger

  authored and

  Elbehery

  committed
  73ae94b

• raftNode: add a new and better way to tell when the node is done

  Show description for c0cac21
  

  mhagger

  authored and

  Elbehery

  committed
  c0cac21

• serveHTTPKVAPI(): monitor the raft node using its "done" channel

  Show description for b19e64f
  

  mhagger

  authored and

  Elbehery

  committed
  b19e64f

• cluster.Close(): read any error from the node directly

  Show description for b4c1a55
  

  mhagger

  authored and

  Elbehery

  committed
  b4c1a55

• TestProposeOnCommit(): read any error from the node directly

  Show description for d420ab3
  

  mhagger

  authored and

  Elbehery

  committed
  d420ab3

• cluster.Cleanup(): new method, extracted from Close()

  Show description for d181e4a
  

  mhagger

  authored and

  Elbehery

  committed
  d181e4a

• TestProposeOnCommit(): change test to use ProcessCommits()

  Show description for 0ae9c56
  

  mhagger

  authored and

  Elbehery

  committed
  0ae9c56

• newRaftNode(): don't return commitC and errorC

  Show description for 848ee9d
  

  mhagger

  authored and

  Elbehery

  committed
  848ee9d

• add raft example

  Elbehery

  committed
  cd6fbb1