pub struct Crc16SoloPartitioner;Expand description
Default SoloPartitioner: crc16_ccitt(lane_utf8) % num_flow_partitions.
Matches the hashing used by flow_partition, budget_partition,
quota_partition — same crc16-CCITT algorithm Valkey Cluster uses
for slot assignment.
Trait Implementations§
Source§impl Clone for Crc16SoloPartitioner
impl Clone for Crc16SoloPartitioner
Source§fn clone(&self) -> Crc16SoloPartitioner
fn clone(&self) -> Crc16SoloPartitioner
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for Crc16SoloPartitioner
impl Debug for Crc16SoloPartitioner
Source§impl Default for Crc16SoloPartitioner
impl Default for Crc16SoloPartitioner
Source§fn default() -> Crc16SoloPartitioner
fn default() -> Crc16SoloPartitioner
Returns the “default value” for a type. Read more
Source§impl SoloPartitioner for Crc16SoloPartitioner
impl SoloPartitioner for Crc16SoloPartitioner
Source§fn partition_for_lane(&self, lane: &LaneId, config: &PartitionConfig) -> u16
fn partition_for_lane(&self, lane: &LaneId, config: &PartitionConfig) -> u16
Return the partition index for a solo execution on the given lane. Read more
impl Copy for Crc16SoloPartitioner
Auto Trait Implementations§
impl Freeze for Crc16SoloPartitioner
impl RefUnwindSafe for Crc16SoloPartitioner
impl Send for Crc16SoloPartitioner
impl Sync for Crc16SoloPartitioner
impl Unpin for Crc16SoloPartitioner
impl UnsafeUnpin for Crc16SoloPartitioner
impl UnwindSafe for Crc16SoloPartitioner
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