leaves 0.5.0

Distributed ID Allocator
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::sync::Arc;

use leaves::{Leaf, LeafDao, SegmentIDGen};

#[tokio::test]
async fn test_with_redis() {
    dotenv::dotenv().ok();
    let mut config = std::env::var("REDIS_URL").expect("REDIS_URL").split(' ');
    let (address, password) = (config.next().unwrap(), config.next());
    let dao = Arc::new(
        leaves::dao::redis::RedisDao::new(address, password)
            .await
            .unwrap(),
    );
    let mut service = SegmentIDGen::new(dao.clone());
    service.init().await.unwrap();
    // dao.insert(Leaf {
    //     tag: 1,
    //     max_id: 0,
    //     step: 1000,
    // })
    // .await
    // .unwrap();
    for _ in 0..10000 {
        service.get(1).await.unwrap();
    }
}