overclock 0.1.13

A framework for building data-driven distributed systems
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
53
54
55
56
57
58
59
60

// Copyright 2022 Louay Kamel
// Copyright 2021 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

use super::{file::FileSystemConfig, *};

/// Specifies that the implementor should be able to persist itself
pub trait Persist {
    /// Persist this value
    fn persist(&self) -> anyhow::Result<()>;
}

/// A handle which will persist when dropped
pub struct PersistHandle<'a, C: 'a + Config + Persist + FileSystemConfig>
where
    HistoricalConfig<C>: FileSystemConfig,
{
    guard: tokio::sync::RwLockWriteGuard<'a, History<HistoricalConfig<C>>>,
}

impl<'a, C: Config + Persist + FileSystemConfig> From<tokio::sync::RwLockWriteGuard<'a, History<HistoricalConfig<C>>>>
    for PersistHandle<'a, C>
where
    HistoricalConfig<C>: FileSystemConfig,
{
    fn from(guard: tokio::sync::RwLockWriteGuard<'a, History<HistoricalConfig<C>>>) -> Self {
        Self { guard }
    }
}

impl<'a, C: Config + Persist + FileSystemConfig> Deref for PersistHandle<'a, C>
where
    HistoricalConfig<C>: FileSystemConfig,
{
    type Target = tokio::sync::RwLockWriteGuard<'a, History<HistoricalConfig<C>>>;

    fn deref(&self) -> &Self::Target {
        &self.guard
    }
}

impl<'a, C: Config + Persist + FileSystemConfig> DerefMut for PersistHandle<'a, C>
where
    HistoricalConfig<C>: FileSystemConfig,
{
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.guard
    }
}

impl<'a, C: Config + Persist + FileSystemConfig> std::ops::Drop for PersistHandle<'a, C>
where
    HistoricalConfig<C>: FileSystemConfig,
{
    fn drop(&mut self) {
        if let Err(e) = self.persist() {
            error!("{}", e);
        }
    }
}