Struct K2KBroker 

pub struct K2KBroker {
    config: K2KConfig,
    endpoints: RwLock<RawRwLock, HashMap<KernelId, Sender<K2KMessage>>>,
    message_counter: AtomicU64,
    receipts: RwLock<RawRwLock, HashMap<MessageId, DeliveryReceipt>>,
    routing_table: RwLock<RawRwLock, HashMap<KernelId, KernelId>>,
}

K2K message broker for routing messages between kernels.

Fields

config: K2KConfig

endpoints: RwLock<RawRwLock, HashMap<KernelId, Sender<K2KMessage>>>

message_counter: AtomicU64

receipts: RwLock<RawRwLock, HashMap<MessageId, DeliveryReceipt>>

routing_table: RwLock<RawRwLock, HashMap<KernelId, KernelId>>

Implementations

impl K2KBroker

pub fn new(config: K2KConfig) -> Arc<K2KBroker>

Create a new K2K broker.

pub fn register(self: &Arc<K2KBroker>, kernel_id: KernelId) -> K2KEndpoint

Register a kernel endpoint.

pub fn unregister(&self, kernel_id: &KernelId)

Unregister a kernel endpoint.

pub fn is_registered(&self, kernel_id: &KernelId) -> bool

Check if a kernel is registered.

pub fn registered_kernels(&self) -> Vec<KernelId>

Get all registered kernels.

pub async fn send( &self, source: KernelId, destination: KernelId, envelope: MessageEnvelope, ) -> Result<DeliveryReceipt, RingKernelError>

Send a message from one kernel to another.

pub async fn send_priority( &self, source: KernelId, destination: KernelId, envelope: MessageEnvelope, priority: u8, ) -> Result<DeliveryReceipt, RingKernelError>

Send a priority message.

pub fn add_route(&self, destination: KernelId, next_hop: KernelId)

Add a route to the routing table.

pub fn remove_route(&self, destination: &KernelId)

Remove a route from the routing table.

pub fn stats(&self) -> K2KStats

Get statistics.

pub fn get_receipt(&self, message_id: &MessageId) -> Option<DeliveryReceipt>

Get delivery receipt for a message.