durable-actors 0.8.1

Standalone regional durable-actors control plane, host, and durability runtime
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

use super::{RequestCompletion, SqliteSnapshot, StateAttribution, StateSnapshot};
use serde::Deserialize;
use serde_json::Value;

pub(super) fn decode(bytes: &[u8]) -> serde_json::Result<StateSnapshot> {
    let legacy: LegacySnapshot = serde_json::from_slice(bytes)?;
    Ok(StateSnapshot {
        attribution: legacy.attribution,
        state_version: legacy.state_version,
        owner_epoch: legacy.owner_epoch,
        request_id: legacy.request_id,
        sqlite: legacy.sqlite,
        completion: Some(RequestCompletion {
            result: legacy.result,
        }),
    })
}

#[derive(Deserialize)]
#[serde(rename_all = "camelCase", deny_unknown_fields)]
struct LegacySnapshot {
    attribution: Option<StateAttribution>,
    state_version: u64,
    owner_epoch: u64,
    request_id: String,
    sqlite: SqliteSnapshot,
    #[serde(deserialize_with = "Value::deserialize")]
    result: Value,
}

#[cfg(test)]
#[path = "../../tests/unit/state_log_legacy.rs"]
mod tests;