Struct StreamingEngine 

pub struct StreamingEngine { /* private fields */ }

The main streaming engine for pub/sub and CDC.

Implementations

impl StreamingEngine

pub fn new() -> Self

Create a new streaming engine.

pub fn with_config(config: EngineConfig) -> Self

Create an engine with custom configuration.

pub fn create_channel( &self, id: impl Into<ChannelId>, ) -> Result<(), EngineError>

Create a new channel.

pub fn create_channel_with_config( &self, id: impl Into<ChannelId>, config: ChannelConfig, ) -> Result<(), EngineError>

Create a channel with custom configuration.

pub fn delete_channel(&self, id: &ChannelId) -> Result<(), EngineError>

Delete a channel.

pub fn list_channels(&self) -> Vec<ChannelId>

List all channels.

pub fn channel_exists(&self, id: &ChannelId) -> bool

Check if a channel exists.

pub fn publish( &self, channel_id: &ChannelId, event: Event, ) -> Result<usize, EngineError>

Publish an event to a channel.

pub fn publish_change( &self, channel_id: &ChannelId, change: ChangeEvent, ) -> Result<usize, EngineError>

Publish a CDC change event.

pub fn publish_to_many( &self, channel_ids: &[ChannelId], event: Event, ) -> HashMap<ChannelId, Result<usize, EngineError>>

Publish to multiple channels.

pub fn subscribe( &self, channel_id: &ChannelId, subscriber_id: impl Into<SubscriberId>, ) -> Result<ChannelReceiver, EngineError>

Subscribe to a channel.

pub fn subscribe_with_filter( &self, channel_id: &ChannelId, subscriber_id: impl Into<SubscriberId>, filter: EventFilter, ) -> Result<ChannelReceiver, EngineError>

Subscribe with a filter.

pub fn unsubscribe(&self, channel_id: &ChannelId, subscriber_id: &SubscriberId)

Unsubscribe from a channel.

pub fn get_subscriber(&self, id: &SubscriberId) -> Option<Subscriber>

Get a subscriber.

pub fn list_subscribers(&self) -> Vec<SubscriberId>

List all subscribers.

pub fn remove_subscriber(&self, id: &SubscriberId)

Remove a subscriber.

pub fn get_history( &self, channel_id: &ChannelId, count: usize, ) -> Result<Vec<Event>, EngineError>

Get recent events from a channel.

pub fn get_history_after( &self, channel_id: &ChannelId, timestamp: u64, ) -> Result<Vec<Event>, EngineError>

Get events after a timestamp.

pub fn stats(&self) -> EngineStats

Get engine statistics.

pub fn reset_stats(&self)

Reset statistics.

pub fn channel_stats(&self, id: &ChannelId) -> Option<ChannelStats>

Get channel statistics.

Trait Implementations

impl Default for StreamingEngine

fn default() -> Self

Returns the “default value” for a type.