echosrv 0.3.0

//! Unix Domain Socket implementations for the echo server
//!
//! This module provides both stream-based and datagram-based Unix domain socket
//! echo servers and clients. Unix domain sockets provide efficient inter-process
//! communication on Unix-like systems.
//!
//! # Examples
//!
//! ## Unix Stream Server
//!
//! ```no_run
//! use echosrv::unix::{UnixStreamConfig, UnixStreamEchoServer};
//! use echosrv::common::EchoServerTrait;
//! use std::time::Duration;
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     let config = UnixStreamConfig {
//!         socket_path: "/tmp/echo.sock".into(),
//!         max_connections: 100,
//!         buffer_size: 1024,
//!         read_timeout: Duration::from_secs(30),
//!         write_timeout: Duration::from_secs(30),
//!     };
//!
//!     let server = UnixStreamEchoServer::new(config.into());
//!     server.run().await?;
//!     Ok(())
//! }
//! ```
//!
//! ## Unix Datagram Server
//!
//! ```no_run
//! use echosrv::unix::{UnixDatagramConfig, UnixDatagramEchoServer};
//! use echosrv::common::EchoServerTrait;
//! use std::time::Duration;
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error>> {
//!     let config = UnixDatagramConfig {
//!         socket_path: "/tmp/echo_dgram.sock".into(),
//!         buffer_size: 1024,
//!         read_timeout: Duration::from_secs(30),
//!         write_timeout: Duration::from_secs(30),
//!     };
//!
//!     let server = UnixDatagramEchoServer::new(config.into());
//!     server.run().await?;
//!     Ok(())
//! }
//! ```

pub mod client;
pub mod config;
pub mod datagram_protocol;
pub mod server;
pub mod stream_protocol;

#[cfg(test)]
mod tests;

// Re-export configuration types
pub use config::{UnixDatagramConfig, UnixStreamConfig};

// Re-export server and client types
pub use client::{UnixDatagramEchoClient, UnixStreamEchoClient};
pub use server::{UnixDatagramEchoServer, UnixStreamEchoServer};

// Re-export protocol implementations
pub use stream_protocol::{Protocol, StreamExt};