aerostream-client 0.1.0

Official production-grade Rust client SDK for the AeroStream native binary protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! Production-grade Rust client SDK for the AeroStream native binary protocol.
//! Provides low-latency async publishing, consuming, and connection pooling.
//! Operates over TCP framing with zero-copy buffer parsing and automatic retries.

pub mod client;
pub mod connection;
pub mod consumer;
pub mod error;
pub mod producer;
pub mod protocol;

// Re-export core primitives for ergonomic top-level crate usage.
pub use client::{AeroClient, ClientConfig, ClientConfigBuilder};
pub use connection::{AeroConnection, TransportStream};
pub use consumer::{AeroConsumer, ConsumerConfig, ConsumerConfigBuilder, RecordStream};
pub use error::AeroError;
pub use producer::{AeroProducer, ProducerConfig, ProducerConfigBuilder};
pub use protocol::{Command, Record, MAGIC, STATUS_AUTH_FAILED, STATUS_DATA, STATUS_EMPTY, STATUS_OK, STATUS_OUT_OF_ORDER};