Enum nakadi_types::event_type::PartitionStrategy

pub enum PartitionStrategy {
    Random,
    Hash,
    UserDefined,
}

Determines how the assignment of the event to a partition should be handled.

The default is random.

See also Nakadi Manual

Variants

Random

Resolution of the target partition happens randomly (events are evenly distributed on the topic’s partitions).

Hash

Resolution of the partition follows the computation of a hash from the value of the fields indicated in the EventType’s partition_key_fields, guaranteeing that Events with same values on those fields end in the same partition. Given the event type’s category is DataChangeEvent, field path is considered relative to “data”.

UserDefined

Target partition is defined by the client. As long as the indicated partition exists, Event assignment will respect this value. Correctness of the relative ordering of events is under the responsibility of the Producer. Requires that the client provides the target partition on metadata.partition (See EventMetadata). Failure to do so will reject the publishing of the Event.

Trait Implementations

impl Clone for PartitionStrategy

fn clone(&self) -> PartitionStrategy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionStrategy

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

Formats the value using the given formatter.

impl Default for PartitionStrategy

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PartitionStrategy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<PartitionStrategy> for PartitionStrategy

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

This method tests for self and other values to be equal, and is used by ==.

#[must_use]

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

This method tests for !=.

impl Serialize for PartitionStrategy

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

Serialize this value into the given Serde serializer.

impl Copy for PartitionStrategy

impl Eq for PartitionStrategy

impl StructuralEq for PartitionStrategy

impl StructuralPartialEq for PartitionStrategy