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 cdc;
16pub mod channel;
17pub mod engine;
18pub mod event;
19pub mod stream;
20pub mod subscriber;
21
22pub use cdc::{CdcConfig, ChangeEvent, ChangeType};
23pub use channel::{Channel, ChannelId};
24pub use engine::StreamingEngine;
25pub use event::{Event, EventId, EventType};
26pub use stream::{EventStream, StreamProcessor};
27pub use subscriber::{ConsumerGroup, Subscriber, SubscriberId, Subscription};