Expand description
Aegis Streaming - Real-Time Event Processing
Event streaming and change data capture for real-time data processing. Supports pub/sub messaging, event sourcing, and CQRS patterns.
Key Features:
- Change data capture (CDC) with configurable triggers
- WebSocket and Server-Sent Events support
- Pub/sub messaging with persistent subscriptions
- Event sourcing and CQRS support
@version 0.1.0 @author AutomataNexus Development Team
Re-exports§
pub use cdc::CdcConfig;pub use cdc::ChangeEvent;pub use cdc::ChangeType;pub use channel::Channel;pub use channel::ChannelId;pub use engine::StreamingEngine;pub use event::Event;pub use event::EventId;pub use event::EventType;pub use stream::EventStream;pub use stream::StreamProcessor;pub use subscriber::ConsumerGroup;pub use subscriber::Subscriber;pub use subscriber::SubscriberId;pub use subscriber::Subscription;