Struct K2KBroker 

pub struct K2KBroker { /* private fields */ }

K2K message broker for routing messages between kernels.

Implementations

impl K2KBroker

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

Create a new K2K broker.

pub fn register(self: &Arc<Self>, 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>

Send a message from one kernel to another.

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

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.