raftor

Distributed websocket chat

this is an experimental project that distribute websocket connections over a cluster.

This project is built on top of actix and actix-raft

How to run

In Config.toml list your nodes under [[nodes]]

Every node has a private_addr and a public_addr

private_addr is the network address used for internal communication

and public_addr is the network address exposed to the world.

cargo run CLUSTER_ADDRESS APP_ADDRESS PUBLIC_ADDRESS

Run in single node cargo run 127.0.0.1:8000 127.0.0.1:9000 127.0.0.1:8080

Run cluster

cargo run 127.0.0.1:8000 127.0.0.1:9000 127.0.0.1:8080

cargo run 127.0.0.1:8001 127.0.0.1:9001 127.0.0.1:8081

cargo run 127.0.0.1:8002 127.0.0.1:9002 127.0.0.1:8082

API

Create room /room/<Name>

TODO:

• Initiate cluster discovery
• Implement actix-raft
• Verify raft is working and replicating state across cluster
• Refactor hash_ring to Arc in order to reduce complexity
• Error handling
• Fix rejoin bug
• Rehash entities when hash ring topology changes
• Building js client