Struct Channel 

pub struct Channel { /* private fields */ }

A pub/sub channel for event distribution.

Implementations

impl Channel

pub fn new(id: impl Into<ChannelId>) -> Self

Create a new channel.

pub fn with_config(id: impl Into<ChannelId>, config: ChannelConfig) -> Self

Create a channel with custom configuration.

pub fn id(&self) -> &ChannelId

Get the channel ID.

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

Publish an event to the channel.

pub fn subscribe( &self, subscriber_id: SubscriberId, ) -> Result<ChannelReceiver, ChannelError>

Subscribe to the channel.

pub fn subscribe_with_filter( &self, subscriber_id: SubscriberId, filter: EventFilter, ) -> Result<ChannelReceiver, ChannelError>

Subscribe with a filter.

pub fn subscribe_with_ack_mode( &self, subscriber_id: SubscriberId, filter: Option<EventFilter>, ack_mode: AckMode, ) -> Result<ChannelReceiver, ChannelError>

Subscribe with a specific ack mode.

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

Unsubscribe from the channel.

pub fn subscriber_count(&self) -> usize

Get the number of subscribers.

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

Get recent events from history.

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

Get events from history after a timestamp.

pub fn stats(&self) -> ChannelStats

Get channel statistics.

pub fn clear_history(&self)

Clear history.