reductstore 1.19.6

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

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

mod bucket_available;
mod bucket_unavailable;
mod initial_state;

use crate::replication::remote_bucket::ErrorRecordMap;
use crate::replication::Transaction;
use async_trait::async_trait;
pub(super) use initial_state::InitialState;
use reduct_base::error::ReductError;
use reduct_base::io::BoxedReadRecord;

/// A state of the remote bucket.

#[async_trait]
pub(super) trait RemoteBucketState {
    /// Write a record to the remote bucket.
    async fn write_batch(
        self: Box<Self>,
        entry_name: &str,
        records: Vec<(BoxedReadRecord, Transaction)>,
    ) -> Box<dyn RemoteBucketState + Sync + Send>;

    /// Probe the remote bucket to check availability without writing.
    async fn probe(self: Box<Self>) -> Box<dyn RemoteBucketState + Sync + Send>;

    /// Is the bucket available?
    fn is_available(&self) -> bool;

    // Get the last result of the write operation.
    fn last_result(&self) -> &Result<ErrorRecordMap, ReductError>;
}