lol

A Raft implementation in Rust language. To support this project please give it a ⭐

Documentation

Features

• Implements all basic Raft features: Replication, Leader Election, Log Compaction, Persistency, Dynamic Membership Change, Streaming Snapshot, etc.
• Based on Tonic and efficient gRPC streaming is fully utilized in log replication and snapshot copying.
• Phi Accrual Failure Detector is used in leader failure detection. This adaptive algorithm lets you not choose a fixed timeout number before deployment and makes it possible to deploy Raft node in Geo-distributed environment. This algorithm is also used in Akka.
• Clear Abstractions: RaftApp is your application or state machine in Raft's context. RaftStorage is the abstraction of the backend storage with which both in-memory and persistent (backed by RocksDB) are supported.

Usage

Add this to your Cargo.toml.

[dependencies] lol-core = "0.9"

Available feature flags:

• simple: Enables SimpleRaftApp.
• gateway: Enables Gateway to interact with the cluster.
• rocksdb-backend: Enables RocksDB-backed RaftStorage.

Example

rust // Implement RaftApp for YourApp! struct YourApp { ... } impl RaftApp for YourApp { ... } // Initialize your app. let app = YourApp { ... }; // Choose a backend. let storage = storage::memory::Storage::new(); // This is the Id of this node. let uri = "https://192.168.10.15:50000".parse().unwrap(); let config = ConfigBuilder::default().build().unwrap(); // Make a tower::Service. let service = make_raft_service(app, storage, uri, config); // Start a gRPC server with the service. tonic::transport::Server::builder() .add_service(service) .serve(socket).await;

Related Projects

• lol-perf: Performance analysis project which utilizes cargo-flamegraph and cargo-profiler.
• phi-detector: Implementation of Phi Accrual Failure Detector.

Development

Use docker container to make an dev environment on your computer.

• make to build the docker image
• ./dev to start the dev container

then

• cargo build to compile the entire project
• make test to run the regression tests
• make bench to run the benchmark tests