Struct PubSubBroker 

pub struct PubSubBroker {
    config: PubSubConfig,
    sender: Sender<Publication>,
    subscriptions: RwLock<RawRwLock, HashMap<u64, SubscriptionInfo>>,
    subscription_counter: AtomicU64,
    topic_stats: RwLock<RawRwLock, HashMap<Topic, TopicStats>>,
    retained: RwLock<RawRwLock, HashMap<Topic, Vec<Publication>>>,
    sequence: AtomicU64,
}

Pub/sub message broker.

Fields

config: PubSubConfig

sender: Sender<Publication>

subscriptions: RwLock<RawRwLock, HashMap<u64, SubscriptionInfo>>

subscription_counter: AtomicU64

topic_stats: RwLock<RawRwLock, HashMap<Topic, TopicStats>>

retained: RwLock<RawRwLock, HashMap<Topic, Vec<Publication>>>

sequence: AtomicU64

Implementations

impl PubSubBroker

pub fn new(config: PubSubConfig) -> Arc<PubSubBroker>

Create a new pub/sub broker.

pub fn subscribe( self: &Arc<PubSubBroker>, subscriber: KernelId, pattern: Topic, ) -> Subscription

Subscribe to a topic.

pub fn unsubscribe(&self, subscription_id: u64)

Unsubscribe by subscription ID.

pub fn publish( &self, topic: Topic, publisher: KernelId, envelope: MessageEnvelope, timestamp: HlcTimestamp, ) -> Result<u64, RingKernelError>

Publish a message to a topic.

pub fn publish_qos( &self, topic: Topic, publisher: KernelId, envelope: MessageEnvelope, timestamp: HlcTimestamp, qos: QoS, ) -> Result<u64, RingKernelError>

Publish with QoS setting.

pub fn publish_retained( &self, topic: Topic, publisher: KernelId, envelope: MessageEnvelope, timestamp: HlcTimestamp, ) -> Result<u64, RingKernelError>

Publish a retained message.

pub fn get_retained(&self, topic: &Topic) -> Vec<Publication>

Get retained messages for a topic.

pub fn clear_retained(&self, topic: &Topic)

Clear retained messages for a topic.

pub fn topic_info(&self, topic: &Topic) -> Option<TopicInfo>

Get topic information.

pub fn list_topics(&self) -> Vec<Topic>

List all topics with subscribers.

pub fn stats(&self) -> PubSubStats

Get broker statistics.