3 unstable releases
0.1.1 | Apr 25, 2023 |
---|---|
0.1.0 | Mar 28, 2023 |
0.0.4 | Sep 26, 2022 |
#428 in Database interfaces
103 downloads per month
21KB
445 lines
rslock - Redlock for Redis in Rust
This is an implementation of Redlock, the distributed locking mechanism built on top of Redis.
Features
- Lock extending
- Async runtime support (tokio)
- Async redis
Install
cargo add rslock
Build
cargo build --release
Usage
use rslock::LockManager;
#[tokio::main]
async fn main() {
let rl = LockManager::new(vec![
"redis://127.0.0.1:6380/",
"redis://127.0.0.1:6381/",
"redis://127.0.0.1:6382/",
]);
let lock;
loop {
// Create the lock
if let Ok(l) = rl.lock("mutex".as_bytes(), 1000).await {
lock = l;
break;
}
}
// Extend the lock
match rl.extend(&lock, 1000).await {
Ok(_) => println!("lock extended!"),
Err(_) => println!("lock couldn't be extended"),
}
// Unlock the lock
rl.unlock(&lock).await;
}
Extending Locks
It should be noted that "extending" locks actually just renews them. For example, when you extend a 1000ms lock after 500ms have elapsed by another 1000ms, the lock will live for a total of 1500ms. It does not add additional time the the existing lock. This is how it was implemented in the Node.js version of Redlock and it will remain that way to be consistent. See the extend script.
Tests
Run tests with:
cargo test
Contribute
If you find bugs or want to help otherwise, please open an issue.
License
BSD. See LICENSE.
Dependencies
~7–14MB
~276K SLoC