Struct ProducerWrite
pub struct ProducerWrite {
pub id: String,
pub seq: u64,
}Expand description
A foreign (non-client) writer’s durable identity: a stable, low-cardinality id plus that
producer’s own gapless sequence (design 306 §4). The same (producer, sequence) model Kafka
uses — dedup AND ordering, bounded by producer count rather than by write volume.
The contract this imposes on the caller: number your writes 1, 2, 3, … and submit them in
order. Concurrency is expressed by using several producer ids, not by fanning out unordered
under one — a concurrent fan-out under a single id draws spurious
ProducerGap rejections.
Fields§
§id: String§seq: u64Trait Implementations§
§impl Clone for ProducerWrite
impl Clone for ProducerWrite
§fn clone(&self) -> ProducerWrite
fn clone(&self) -> ProducerWrite
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 more§impl Debug for ProducerWrite
impl Debug for ProducerWrite
§impl PartialEq for ProducerWrite
impl PartialEq for ProducerWrite
impl Eq for ProducerWrite
impl StructuralPartialEq for ProducerWrite
Auto Trait Implementations§
impl Freeze for ProducerWrite
impl RefUnwindSafe for ProducerWrite
impl Send for ProducerWrite
impl Sync for ProducerWrite
impl Unpin for ProducerWrite
impl UnsafeUnpin for ProducerWrite
impl UnwindSafe for ProducerWrite
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.