Implementing multi-paxos with gRPC framework

Another system we built - ZooKeeper Atomic Broadcast written in Go

System Structure

Client/main.go

• send operations
• periodically check performed operations

Replica/main.go

• receive client operations, assign slot number
• send proposal to leaders
• peridoically check decided proposals
• maintain sequencial consistency of how operations are performed

Leader/main.go

• receive replica proposals, assign ballot number
• send Commanders to ask for acceptor quorum consent
• use Scout to maintain the invariant that only one active leader at a time
• update ballot number when the previous active leader is down
• avoid unstable leadership by sending and receiving hearbeats

system testing setup and port assginment

• 2 clients (50051, 50052)
• 2 replicas (50053, 50054)
• 2 leaders (50055, 50056)
• 3 acceptors (50057, 50058, 50059)