Struct Partitioning 

pub struct Partitioning {
    pub kind: PartitioningKind,
    pub length: u8,
    pub value: Vec<u8>,
}

Partitioning is used to specify to which partition the messages should be sent. It has the following kinds:

• Balanced - the partition ID is calculated by the server using the round-robin algorithm.
• PartitionId - the partition ID is provided by the client.
• MessagesKey - the partition ID is calculated by the server using the hash of the provided messages key.

Fields

kind: PartitioningKind

The kind of partitioning.

length: u8

The length of the value payload.

value: Vec<u8>

The binary value payload.

Implementations

impl Partitioning

pub fn balanced() -> Self

Partition the messages using the balanced round-robin algorithm on the server.

pub fn partition_id(partition_id: u32) -> Self

Partition the messages using the provided partition ID.

pub fn messages_key(value: &[u8]) -> Result<Self, IggyError>

Partition the messages using the provided messages key.

pub fn messages_key_str(value: &str) -> Result<Self, IggyError>

Partition the messages using the provided messages key as str.

pub fn messages_key_u32(value: u32) -> Self

Partition the messages using the provided messages key as u32.

pub fn messages_key_u64(value: u64) -> Self

Partition the messages using the provided messages key as u64.

pub fn messages_key_u128(value: u128) -> Self

Partition the messages using the provided messages key as u128.

pub fn from_partitioning(partitioning: &Partitioning) -> Self

Create the partitioning from the provided partitioning.

pub fn from_raw_bytes(bytes: &[u8]) -> Result<Self, IggyError>

Create the partitioning from a raw byte slice.

pub const fn maximum_byte_size() -> usize

Maximum size of the Partitioning struct

Trait Implementations

impl BytesSerializable for Partitioning

fn to_bytes(&self) -> Bytes

Serializes the struct to bytes.

fn from_bytes(bytes: Bytes) -> Result<Self, IggyError>

where Self: Sized,

Deserializes the struct from bytes.

fn write_to_buffer(&self, bytes: &mut BytesMut)

Write the struct to a buffer.

fn get_buffer_size(&self) -> usize

Get the byte-size of the struct.

impl Clone for Partitioning

fn clone(&self) -> Partitioning

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Partitioning

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

Formats the value using the given formatter.

impl Default for Partitioning

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Partitioning

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Partitioning

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

Formats the value using the given formatter.

impl Hash for Partitioning

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Partitioning

fn eq(&self, other: &Partitioning) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Partitioning

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Sizeable for Partitioning

fn get_size_bytes(&self) -> IggyByteSize

impl Eq for Partitioning

impl StructuralPartialEq for Partitioning