nodedb-bridge 0.2.1

Lock-free SPSC ring buffer bridging Tokio (Send) and Thread-per-Core (! Send) runtimes
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

// SPDX-License-Identifier: BUSL-1.1

/// Errors produced by the cross-runtime bridge.
#[derive(Debug, thiserror::Error)]
pub enum BridgeError {
    /// The ring buffer is full and the producer cannot enqueue.
    /// The caller should yield and retry after the consumer drains.
    #[error("ring buffer full (capacity: {capacity}, pending: {pending})")]
    Full { capacity: usize, pending: usize },

    /// The ring buffer is empty and the consumer has nothing to dequeue.
    #[error("ring buffer empty")]
    Empty,

    /// The other side of the channel has been dropped.
    #[error("channel disconnected: {side} side dropped")]
    Disconnected { side: &'static str },

    /// Backpressure threshold exceeded — the caller must throttle.
    #[error("backpressure: queue utilization at {percent}% (threshold: {threshold}%)")]
    Backpressure { percent: u8, threshold: u8 },

    /// Request deadline expired before the Data Plane could process it.
    #[error("deadline exceeded for request {request_id}")]
    DeadlineExceeded { request_id: u64 },
}

pub type Result<T> = std::result::Result<T, BridgeError>;