Struct AllocateMessageQueueConsistentHash 

pub struct AllocateMessageQueueConsistentHash { /* private fields */ }

Assigns queues through a consistent hash ring of consumer ids.

Implementations

impl AllocateMessageQueueConsistentHash

pub fn new(virtual_node_count: i32) -> Self

pub fn try_new(virtual_node_count: i32) -> Result<Self>

pub fn with_hash_function( virtual_node_count: i32, hash_function: Arc<dyn HashFunction + Send + Sync>, ) -> Result<Self>

Trait Implementations

impl AllocateMessageQueueStrategy for AllocateMessageQueueConsistentHash

fn allocate( &self, consumer_group: &CheetahString, current_cid: &CheetahString, mq_all: &[MessageQueue], cid_all: &[CheetahString], ) -> Result<Vec<MessageQueue>>

fn get_name(&self) -> &'static str

impl Clone for AllocateMessageQueueConsistentHash

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AllocateMessageQueueConsistentHash

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AllocateMessageQueueConsistentHash

fn default() -> Self

Returns the “default value” for a type.