proxima-lib 0.1.0

#[cfg(all(
    feature = "amqp-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod amqp;
pub mod callback;
pub mod callback_registry;
#[cfg(all(
    feature = "dns-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod dns;
pub mod fs;
#[cfg(all(
    feature = "http-prime",
    feature = "http2",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod grpc_h2;
#[cfg(all(
    feature = "kafka-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod kafka;
#[cfg(all(
    feature = "memcached-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod memcached;
#[cfg(all(
    feature = "mqtt-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod mqtt;
#[cfg(all(
    feature = "pgwire-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod pgwire;
#[cfg(all(
    feature = "redis-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod redis;
#[cfg(feature = "http1")]
pub use proxima_http::http1::upstream as http;
pub mod kv_cache;
pub mod kv_file;
pub mod kv_upstream;
// child-process upstream: tokio::process::Command supervision +
// tokio::spawn + tokio::sync (mpsc/watch/Mutex/JoinHandle) — a genuine
// tokio::process capability with no prime equivalent today.
#[cfg(feature = "tokio")]
pub mod process;
// newline-framed stdin/stdout RPC to a subprocess — built on
// proxima_process + proxima_core::time + proxima_primitives::sync, no
// tokio surface, so it is not gated behind the `tokio` feature. its
// child-liveness/fd-dup syscalls (waitpid/kill/dup) are unix-only.
#[cfg(unix)]
pub mod process_rpc;
#[cfg(feature = "recording")]
pub mod record;
// guest-ELF-as-upstream: `proxima-vm`'s M1 dispatch loop over KVM/
// Hypervisor.framework — tokio-gated for the same reason `process` is (see
// that module's comment above).
#[cfg(feature = "vm")]
pub mod vm;
#[cfg(feature = "recording")]
pub use proxima_recording::replay;
#[cfg(all(
    feature = "h3-native-upstream",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub mod h3_native;
#[cfg(any(feature = "tcp", feature = "unix"))]
pub mod stream_passthrough;
pub mod synth;
#[cfg(feature = "h3-upstream")]
pub use proxima_http::http3::upstream as h3;
// `proxima_net::tokio` only exists under proxima-net's own `tokio` feature
// (forwarded by this crate's umbrella `tokio` feature) — `tcp`/`unix` alone
// no longer imply it (`tcp` rides `proxima_net::prime::PrimeTcpUpstream` by
// default now).
#[cfg(feature = "websocket-upstream")]
pub use proxima_http::websocket::upstream as websocket;
#[cfg(all(any(feature = "tcp", feature = "unix"), feature = "tokio"))]
pub use proxima_net::tokio::tokio_stream_upstream as tokio_stream;

#[cfg(all(
    feature = "amqp-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use amqp::{AmqpClientProtocol, AmqpPipeFactory};
pub use callback::{CallbackPipeFactory, CallbackUpstream};
pub use callback_registry::{CallbackFn, CallbackFuture, CallbackRegistry, DynCallbackFn};
#[cfg(all(
    feature = "dns-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use dns::{DnsClientProtocol, DnsPipeFactory};
pub use fs::{FsPipeFactory, FsUpstream};
#[cfg(all(
    feature = "http-prime",
    feature = "http2",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use grpc_h2::GrpcH2PipeFactory;
#[cfg(feature = "h3-upstream")]
pub use h3::Http3Upstream;
#[cfg(all(
    feature = "h3-native-upstream",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use h3_native::H3NativeUpstreamFactory;
#[cfg(feature = "http1")]
pub use http::{HttpPipeFactory, HttpUpstream};
#[cfg(all(
    feature = "kafka-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use kafka::{KafkaClientProtocol, KafkaPipeFactory};
pub use kv_cache::{KvCache, KvCacheFactory};
pub use kv_file::{KvFile, KvFileFactory};
pub use kv_upstream::KvUpstream;
#[cfg(all(
    feature = "memcached-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use memcached::{MemcachedClientProtocol, MemcachedPipeFactory};
#[cfg(all(
    feature = "mqtt-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use mqtt::{MqttClientProtocol, MqttPipeFactory};
#[cfg(all(
    feature = "pgwire-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use pgwire::{PgwireClientProtocol, PgwirePipeFactory};
#[cfg(feature = "tokio")]
pub use process::{
    ProcessPipeFactory, ProcessSpec, ProcessUpstream, ReadyProbe, RestartPolicy, ShutdownSignal,
};
#[cfg(unix)]
pub use process_rpc::{ProcessRpcPipeFactory, ProcessRpcSpec, ProcessRpcUpstream};
#[cfg(feature = "recording")]
pub use record::{RecordPipeFactory, RecordUpstream};
#[cfg(all(
    feature = "redis-client",
    any(target_os = "linux", target_os = "macos", target_os = "windows")
))]
pub use redis::{RedisClientProtocol, RedisPipeFactory};
#[cfg(feature = "recording")]
pub use replay::{ReplayPipeFactory, ReplayUpstream};
#[cfg(any(feature = "tcp", feature = "unix"))]
pub use stream_passthrough::{
    StreamPassthroughPipeFactory, StreamPassthroughSettings, StreamPassthroughUpstream,
};
pub use synth::{SynthPipeFactory, SynthUpstream};
#[cfg(all(feature = "tcp", feature = "tokio"))]
pub use tokio_stream::TokioTcpUpstream;
#[cfg(all(feature = "unix", unix, feature = "tokio"))]
pub use tokio_stream::TokioUnixUpstream;
#[cfg(feature = "vm")]
pub use vm::{VmConfig, VmPipeFactory, VmSpec, VmUpstream};
#[cfg(feature = "websocket-upstream")]
pub use websocket::WebSocketUpstream;