aegis_streaming/lib.rs
1//! Aegis Streaming - Real-Time Event Processing
2//!
3//! Event streaming and change data capture for real-time data processing.
4//! Supports pub/sub messaging, event sourcing, and CQRS patterns.
5//!
6//! Key Features:
7//! - Change data capture (CDC) with configurable triggers
8//! - WebSocket and Server-Sent Events support
9//! - Pub/sub messaging with persistent subscriptions
10//! - Event sourcing and CQRS support
11//!
12//! @version 0.1.0
13//! @author AutomataNexus Development Team
14
15pub mod event;
16pub mod channel;
17pub mod subscriber;
18pub mod cdc;
19pub mod stream;
20pub mod engine;
21
22pub use event::{Event, EventId, EventType};
23pub use channel::{Channel, ChannelId};
24pub use subscriber::{Subscriber, SubscriberId, Subscription};
25pub use cdc::{ChangeEvent, ChangeType, CdcConfig};
26pub use stream::{EventStream, StreamProcessor};
27pub use engine::StreamingEngine;