raftos

Install

pip install raftos

Register nodes on every server

import raftos
loop.create_task(
 raftos.register(
 # node running on this machine
 '127.0.0.1:8000',
 # other servers
 cluster=[
 '127.0.0.1:8001',
 '127.0.0.1:8002'
 ]
 )
)
loop.run_forever()

Data replication

counter = raftos.Replicated(name='counter')
data = raftos.ReplicatedDict(name='data')
# value on a leader gets replicated to all followers
await counter.set(42)
await data.update({
 'id': 337,
 'data': {
 'amount': 20000,
 'created_at': '7/11/16 18:45'
 }
})

In case you only need consensus algorithm with leader election

await raftos.wait_until_leader(current_node)

if raftos.get_leader() == current_node:
 # make request or respond to a client

raftos.configure({
 'on_leader': start,
 'on_follower': stop
})