durable-actors 0.5.2

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

use anyhow::Result;
use async_trait::async_trait;

use super::{
    TraceEvent, TracePage,
    history::HistoryQuery,
    metrics::{OverviewMetrics, QueueWaitQuery, QueueWaitRow, SocketSession, TimeRange},
    replay::ReplayQuery,
};

mod cursor;
pub(crate) mod postgres;
pub(crate) mod sqlite;

// TraceStore validates project IDs and query bounds before calling the backends.
#[async_trait]
pub(crate) trait TracePersistence: Send + Sync {
    async fn initialize(&self) -> Result<()>;
    // Events have stable IDs; repeated appends must not duplicate them.
    async fn append(&self, events: &[TraceEvent]) -> Result<()>;
    async fn history(&self, project_id: &str, query: &HistoryQuery) -> Result<TracePage>;
    async fn metrics(&self, project_id: &str, query: &TimeRange) -> Result<OverviewMetrics>;
    async fn queue_waits(
        &self,
        project_id: &str,
        query: &QueueWaitQuery,
    ) -> Result<Vec<QueueWaitRow>>;
    async fn websockets(&self, project_id: &str, query: &TimeRange) -> Result<Vec<SocketSession>>;

    async fn replay(&self, project_id: &str, query: &ReplayQuery) -> Result<TracePage>;
}

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