floxide-redis 3.2.2

Redis implementation for Floxide distributed workflow system
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

mod helpers;

use floxide_core::distributed::context_store::ContextStore;
use floxide_redis::{RedisClient, RedisConfig, RedisContextStore};
use std::fmt::Debug;

#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize, Default)]
struct DummyContext {
    pub value: i32,
}

impl floxide_core::merge::Merge for DummyContext {
    fn merge(&mut self, other: Self) {
        self.value += other.value;
    }
}

#[tokio::test]
async fn test_context_store_set_get_merge() {
    helpers::init_tracing();
    let mut redis = helpers::TestRedis::start().await;
    let config = RedisConfig::new(redis.redis_url());
    let client = RedisClient::new(config).await.expect("redis client");
    let store = RedisContextStore::<DummyContext>::new(client);

    let ctx1 = DummyContext { value: 10 };
    let ctx2 = DummyContext { value: 5 };

    // Set context
    store.set("run1", ctx1.clone()).await.expect("set context");
    // Get context
    let loaded = store
        .get("run1")
        .await
        .expect("get context")
        .expect("context exists");
    assert_eq!(loaded, ctx1);

    // Merge context
    store
        .merge("run1", ctx2.clone())
        .await
        .expect("merge context");
    let merged = store
        .get("run1")
        .await
        .expect("get context")
        .expect("context exists");
    assert_eq!(merged.value, ctx1.value + ctx2.value);

    redis.cleanup().await;
}