proxima-primitives 0.1.0

The pipe algebra itself: the Pipe trait — an async In -> Result<Out, Err> that becomes a transform, source, sink or observe by choice of types — plus its three tier siblings (SendPipe, UnpinPipe, UnpinSendPipe), Handler, SourcePipe, the payload types Carry, ResponseStream and RequestStream (buffered bodies are plain Bytes), HeaderList, the sans-IO byte-stream traits, runtime-agnostic concurrency primitives, and the Replay/GenericStream transport seam. Everything else in proxima composes what is defined here.
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

use alloc::sync::Arc;
use bytes::Bytes;

use crate::pipe::request::{Request, Response};
use crate::pipe::telemetry_surface::{Labels, NoopTelemetry, TelemetryHandle};

/// Telemetry sink + base labels for a payload (HTTP: the request context).
///
/// Implement this on any input type to make `Retry` and `RateLimit` emit
/// telemetry. HTTP implements it on `Request` and `Response`.
pub trait Labeled {
    fn telemetry(&self) -> TelemetryHandle;
    fn labels(&self) -> Labels;
}

impl Labeled for Request<Bytes> {
    fn telemetry(&self) -> TelemetryHandle {
        self.context.telemetry.clone()
    }

    fn labels(&self) -> Labels {
        self.context.metric_labels(&[])
    }
}

impl Labeled for Response<Bytes> {
    fn telemetry(&self) -> TelemetryHandle {
        Arc::new(NoopTelemetry)
    }

    fn labels(&self) -> Labels {
        Labels::empty()
    }
}