durable-streams-server 0.3.0

Durable Streams protocol server in Rust, built with axum and tokio
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

//! Export and import of stream data for backup, restore, and migration.
//!
//! This module provides a versioned JSON format that captures stream metadata
//! and message payloads (base64-encoded) so they can be moved between storage
//! backends, backed up to external systems, or restored after data loss.
//!
//! # Modules
//!
//! - [`mod@format`] — serde types for the JSON document schema
//! - [`export`] — reads streams from storage and writes JSON
//! - [`import`] — reads JSON and writes streams into storage

pub mod export;
pub mod format;
pub mod import;

/// Errors that can occur during export or import operations.
#[derive(Debug, thiserror::Error)]
pub enum TransferError {
    /// Underlying I/O failure (file create, write, etc.).
    #[error("I/O error: {0}")]
    Io(#[from] std::io::Error),

    /// JSON serialization or deserialization failure.
    #[error("JSON error: {0}")]
    Json(#[from] serde_json::Error),

    /// A message payload could not be decoded from base64.
    #[error("base64 decode error: {0}")]
    Base64(#[from] base64::DecodeError),

    /// The export document declares a format version this build cannot handle.
    #[error("unsupported format version: {0}")]
    UnsupportedVersion(u32),

    /// A storage operation failed during export or import.
    #[error("storage error: {0}")]
    Storage(#[from] crate::protocol::error::Error),

    /// A stream in the import already exists and the conflict policy forbids it.
    #[error("import conflict: stream '{0}' already exists")]
    Conflict(String),
}