Skip to content

Commit

Permalink
chore: fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
jopemachine committed Oct 2, 2024
1 parent 5d90f7f commit e1a12d4
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 15 deletions.
2 changes: 1 addition & 1 deletion binding/python/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ pyo3-asyncio = { version = "0.20.0", features = ["tokio-runtime"] }
pythonize = "0.20.0"
tokio = { version = "1.4", features = ["full"] }
async-trait = "0.1.48"
raftify = { version = "=0.1.78", features = ["heed_storage"] , default-features = false }
raftify = { version = "=0.1.78", features = ["heed_storage"], default-features = false }
raftify_cli = { version = "=0.1.1" }
slog = { version = "2.2", features = ["max_level_trace", "release_max_level_trace"] }
slog-envlogger = "2.1.0"
Expand Down
12 changes: 6 additions & 6 deletions examples/memstore/dynamic-members/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use example_harness::config::build_config;
use memstore_example_harness::{
state_machine::{HashStore, LogEntry, Raft},
web_server_api::{
campaign, debug, demote, get, leader_id, leave, leave_joint, peers, put, snapshot,
campaign, debug, demote, get, leader, leave, leave_joint, peers, put, snapshot,
transfer_leader,
},
};
Expand Down Expand Up @@ -83,11 +83,11 @@ async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {

#[cfg(feature = "heed_storage")]
let log_storage = HeedStorage::create(&cfg.log_dir, &cfg.clone(), logger.clone())
.expect("Failed to create heed storage");
.expect("Failed to create storage");

#[cfg(feature = "rocksdb_storage")]
let log_storage = RocksDBStorage::create(&cfg.log_dir, logger.clone())
.expect("Failed to create heed storage");
.expect("Failed to create storage");

let raft = Raft::bootstrap(
node_id,
Expand Down Expand Up @@ -128,11 +128,11 @@ async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {

#[cfg(feature = "heed_storage")]
let log_storage = HeedStorage::create(&cfg.log_dir, &cfg.clone(), logger.clone())
.expect("Failed to create heed storage");
.expect("Failed to create storage");

#[cfg(feature = "rocksdb_storage")]
let log_storage = RocksDBStorage::create(&storage_pth, logger.clone())
.expect("Failed to create heed storage");
.expect("Failed to create storage");

let raft = Raft::bootstrap(
leader_node_id,
Expand All @@ -158,7 +158,7 @@ async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {
.service(debug)
.service(peers)
.service(snapshot)
.service(leader_id)
.service(leader)
.service(leave_joint)
.service(transfer_leader)
.service(campaign)
Expand Down
6 changes: 3 additions & 3 deletions examples/memstore/src/web_server_api.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ async fn get(data: web::Data<(HashStore, Raft)>, path: web::Path<u64>) -> impl R
}

#[get("/leader")]
async fn leader_id(data: web::Data<(HashStore, Raft)>) -> impl Responder {
async fn leader(data: web::Data<(HashStore, Raft)>) -> impl Responder {
let raft = data.clone();
let leader_id = raft
.1
Expand Down Expand Up @@ -123,7 +123,7 @@ async fn campaign(data: web::Data<(HashStore, Raft)>) -> impl Responder {
#[get("/demote/{term}/{leader_id}")]
async fn demote(data: web::Data<(HashStore, Raft)>, path: web::Path<(u64, u64)>) -> impl Responder {
let raft = data.clone();
let (term, leader_id_) = path.into_inner();
raft.1.demote(term, leader_id_).await.unwrap();
let (term, leader_id) = path.into_inner();
raft.1.demote(term, leader_id).await.unwrap();
"OK".to_string()
}
10 changes: 5 additions & 5 deletions examples/memstore/static-members/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use example_harness::config::build_config;
use memstore_example_harness::{
state_machine::{HashStore, LogEntry, Raft},
web_server_api::{
campaign, debug, demote, get, leader_id, leave, leave_joint, peers, put, snapshot,
campaign, debug, demote, get, leader, leave, leave_joint, peers, put, snapshot,
transfer_leader,
},
};
Expand Down Expand Up @@ -79,11 +79,11 @@ async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {

#[cfg(feature = "heed_storage")]
let log_storage = HeedStorage::create(&cfg.log_dir, &cfg.clone(), logger.clone())
.expect("Failed to create heed storage");
.expect("Failed to create storage");

#[cfg(feature = "rocksdb_storage")]
let log_storage = RocksDBStorage::create(&cfg.log_dir, logger.clone())
.expect("Failed to create heed storage");
let log_storage =
RocksDBStorage::create(&cfg.log_dir, logger.clone()).expect("Failed to create storage");

let raft = Raft::bootstrap(
node_id,
Expand All @@ -107,7 +107,7 @@ async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {
.service(debug)
.service(peers)
.service(snapshot)
.service(leader_id)
.service(leader)
.service(leave_joint)
.service(transfer_leader)
.service(campaign)
Expand Down

0 comments on commit e1a12d4

Please sign in to comment.