aegis-streaming 0.2.6

Real-time streaming for Aegis database
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! 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

pub mod cdc;
pub mod channel;
pub mod engine;
pub mod event;
pub mod stream;
pub mod subscriber;

pub use cdc::{CdcConfig, ChangeEvent, ChangeType};
pub use channel::{Channel, ChannelId};
pub use engine::StreamingEngine;
pub use event::{Event, EventId, EventType};
pub use stream::{EventStream, StreamProcessor};
pub use subscriber::{ConsumerGroup, Subscriber, SubscriberId, Subscription};