skippydb 0.2.2

A high-performance verifiable key-value store with SHA256 Merkle trees and optional CUDA GPU acceleration, designed for blockchain state storage.
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

use super::task::Task;
use crate::utils::changeset::ChangeSet;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

#[derive(Clone, serde::Serialize, serde::Deserialize)]
pub struct SimpleTask {
    #[serde(
        serialize_with = "serialize_arc_vec",
        deserialize_with = "deserialize_arc_vec"
    )]
    pub change_sets: Arc<Vec<ChangeSet>>,
}

fn serialize_arc_vec<S>(value: &Arc<Vec<ChangeSet>>, serializer: S) -> Result<S::Ok, S::Error>
where
    S: serde::Serializer,
{
    value.as_ref().serialize(serializer)
}

fn deserialize_arc_vec<'de, D>(deserializer: D) -> Result<Arc<Vec<ChangeSet>>, D::Error>
where
    D: serde::Deserializer<'de>,
{
    let vec = Vec::deserialize(deserializer)?;
    Ok(Arc::new(vec))
}

impl Task for SimpleTask {
    fn get_change_sets(&self) -> Arc<Vec<ChangeSet>> {
        self.change_sets.clone()
    }
}

impl SimpleTask {
    pub fn new(changesets: Vec<ChangeSet>) -> Self {
        Self {
            change_sets: Arc::new(changesets),
        }
    }
}