reductstore 1.20.8

ReductStore is a time series database designed specifically for storing and managing large amounts of blob data.
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
61
62
63
64
65
66
67
68
69
70
71
72

// Copyright 2021-2026 ReductSoftware UG
// Licensed under the Apache License, Version 2.0

use crate::core::sync::AsyncRwLock;
use crate::syslog::LogSystemEvent;
use async_trait::async_trait;
use reduct_base::error::ReductError;
use reduct_base::msg::lifecycle_api::{
    FullLifecycleInfo, LifecycleInfo, LifecycleMode, LifecycleSettings,
};
use std::sync::Arc;

mod action;
mod lifecycle_repository;
mod lifecycle_task;
pub(crate) mod system_event_payload;

#[derive(Clone)]
pub struct SystemEventSink {
    pub(crate) system_logger: Arc<AsyncRwLock<Box<dyn LogSystemEvent + Send + Sync>>>,
    pub(crate) instance_name: String,
}

#[async_trait]
pub trait ManageLifecycles {
    /// Create a lifecycle policy.
    async fn create_lifecycle(
        &mut self,
        name: &str,
        settings: LifecycleSettings,
    ) -> Result<(), ReductError>;

    /// Update a lifecycle policy.
    async fn update_lifecycle(
        &mut self,
        name: &str,
        settings: LifecycleSettings,
    ) -> Result<(), ReductError>;

    /// List lifecycle policies.
    async fn lifecycles(&self) -> Result<Vec<LifecycleInfo>, ReductError>;

    /// Get lifecycle policy information.
    async fn get_info(&self, name: &str) -> Result<FullLifecycleInfo, ReductError>;

    /// Get lifecycle policy settings.
    async fn get_lifecycle_settings(&self, name: &str) -> Result<LifecycleSettings, ReductError>;

    /// Check if lifecycle worker is running.
    async fn is_lifecycle_running(&self, name: &str) -> Result<bool, ReductError>;

    /// Set lifecycle mode.
    async fn set_mode(&mut self, name: &str, mode: LifecycleMode) -> Result<(), ReductError>;

    /// Mark lifecycle policy as provisioned/unprovisioned.
    async fn set_lifecycle_provisioned(
        &mut self,
        name: &str,
        provisioned: bool,
    ) -> Result<(), ReductError>;

    /// Remove a lifecycle policy.
    async fn remove_lifecycle(&mut self, name: &str) -> Result<(), ReductError>;

    /// Start background workers if they are not running yet.
    async fn start(&mut self) -> Result<(), ReductError>;

    /// Stop background workers and wait until they finish.
    async fn stop(&mut self);
}

pub(crate) use lifecycle_repository::LifecycleRepoBuilder;