proxima-lib 0.1.0

A sans-IO core where everything is a Pipe — one async In -> Result<Out, Err> trait worn four ways (transform, source, sink, observe), composed into proxies, gateways, caches, codecs and telemetry pipelines. Config-driven, runtime-agnostic: the same pipe runs on the from-scratch Prime per-core runtime, on tokio, or on no_std bare metal.
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

// Read/format layer (event model, Format codecs, sources, source registry)
// stays at the proxima-recording crate root (folded from the former
// proxima-recording-core). The SINK half (the RecordingSink trait,
// BinSink/JsonlSink/BroadcastSink, the sink factory/registry) was deleted
// from recording-core and relocated onto the spigot layer in
// proxima-recording's `pipe` module (folded from the former
// proxima-recording-pipe, C7). `sink` aliases that relocated module so
// `crate::recording::sink::{RecordingSink, DynRecordingSink, AppendFuture}`
// keeps resolving for existing consumers.
pub use proxima_recording::binary as bin;
pub use proxima_recording::jsonl;
pub use proxima_recording::{
    BinSource, BinSourceFactory, CacheOutcome, DynRecordingSource, DynRecordingSourceFactory,
    EventSource, FrameMetadata, HttpEvent, INDEX_RECORD_BYTES, IndexReader, IndexRecord,
    IndexWriter, InteractionId, JsonlSource, JsonlSourceFactory, PipelineEvent, PipelineOutcome,
    ProcessEvent, ProtocolEvent, RECORDING_FORMAT_VERSION, RecordMeta, RecordingEvent,
    RecordingEventStream, RecordingSource, RecordingSourceFactory, RecordingSourceRegistry,
    RequestHeader, SourceBuildFuture, event, factory, source,
};

// sink half relocated to the spigot layer.
pub use proxima_recording::pipe::event_sink as sink;
pub use proxima_recording::pipe::{
    AccumulatingSink, AppendAck, AppendFuture, AppendLog, DeferredRuntime, DynRecordingSink,
    EventTap, FanOut, FormatKind, LazyFanOut, RecordingSink, ReplayLog, SinkSpec, TerminalSignal,
    deferred_runtime,
};

pub use proxima_recording::pipe::cap;
pub use proxima_recording::pipe::capture;
// bridges a `ProcessUpstream` (tokio::process-backed, no prime equivalent
// today) into the recording event stream — genuinely tokio-only.
#[cfg(feature = "tokio")]
pub mod process_bridge;

pub use crate::capture_surface::CaptureContext;
#[cfg(feature = "tokio")]
pub use process_bridge::{BridgeHandle, ProcessEventBridge};
pub use proxima_recording::pipe::cap::{
    BoundedRecordingSink, DropReason, FailMode, RECORD_DROP_METRIC,
};
pub use proxima_recording::pipe::capture::LiveCaptureContext;