Struct QueueFactory 

pub struct QueueFactory;

Factory for creating appropriately-sized message queues.

Example

use ringkernel_core::queue::{QueueFactory, QueueTier};

// Create a medium-sized MPSC queue
let queue = QueueFactory::create_mpsc(QueueTier::Medium);

// Create based on expected throughput
let queue = QueueFactory::create_for_throughput(10000, 100); // 10k msg/s, 100ms buffer

Implementations

impl QueueFactory

pub fn create_spsc(tier: QueueTier) -> SpscQueue

Create an SPSC queue with the specified tier.

pub fn create_mpsc(tier: QueueTier) -> MpscQueue

Create an MPSC queue with the specified tier.

pub fn create_bounded(tier: QueueTier) -> BoundedQueue

Create a bounded queue with the specified tier.

pub fn create_for_throughput( messages_per_second: u64, headroom_ms: u64, ) -> Box<dyn MessageQueue>

Create a queue based on expected throughput.

Arguments

• messages_per_second - Expected message throughput
• headroom_ms - Desired buffer time in milliseconds