[−][src]Enum nakadi_types::event_type::PartitionStrategy
Determines how the assignment of the event to a partition should be handled.
The default is random
.
See also Nakadi Manual
Variants
Resolution of the target partition happens randomly (events are evenly distributed on the topic’s partitions).
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”.
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
[src]
pub fn clone(&self) -> PartitionStrategy
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for PartitionStrategy
[src]
impl Debug for PartitionStrategy
[src]
impl Default for PartitionStrategy
[src]
impl<'de> Deserialize<'de> for PartitionStrategy
[src]
pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Eq for PartitionStrategy
[src]
impl PartialEq<PartitionStrategy> for PartitionStrategy
[src]
pub fn eq(&self, other: &PartitionStrategy) -> bool
[src]
#[must_use]pub fn ne(&self, other: &Rhs) -> bool
1.0.0[src]
impl Serialize for PartitionStrategy
[src]
pub fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralEq for PartitionStrategy
[src]
impl StructuralPartialEq for PartitionStrategy
[src]
Auto Trait Implementations
impl RefUnwindSafe for PartitionStrategy
impl Send for PartitionStrategy
impl Sync for PartitionStrategy
impl Unpin for PartitionStrategy
impl UnwindSafe for PartitionStrategy
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,