pub struct AllocateMessageQueueByMachineRoom { /* private fields */ }Expand description
Limits allocation to selected broker machine rooms.
Implementations§
Source§impl AllocateMessageQueueByMachineRoom
impl AllocateMessageQueueByMachineRoom
pub fn new(consumer_idcs: HashSet<CheetahString>) -> Self
Trait Implementations§
Source§impl AllocateMessageQueueStrategy for AllocateMessageQueueByMachineRoom
impl AllocateMessageQueueStrategy for AllocateMessageQueueByMachineRoom
fn allocate( &self, consumer_group: &CheetahString, current_cid: &CheetahString, mq_all: &[MessageQueue], cid_all: &[CheetahString], ) -> Result<Vec<MessageQueue>>
fn get_name(&self) -> &'static str
Auto Trait Implementations§
impl Freeze for AllocateMessageQueueByMachineRoom
impl RefUnwindSafe for AllocateMessageQueueByMachineRoom
impl Send for AllocateMessageQueueByMachineRoom
impl Sync for AllocateMessageQueueByMachineRoom
impl Unpin for AllocateMessageQueueByMachineRoom
impl UnsafeUnpin for AllocateMessageQueueByMachineRoom
impl UnwindSafe for AllocateMessageQueueByMachineRoom
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more