Enum fluvio::DeliverySemantic
source · pub enum DeliverySemantic {
AtMostOnce,
AtLeastOnce(RetryPolicy),
}
Expand description
Defines guarantees that Producer must follow delivering records to SPU.
Variants§
AtMostOnce
Send records without waiting for the response. Fire and forget
approach.
AtLeastOnce(RetryPolicy)
Send records, wait for the response and retry if an error occurs. Retry parameters,
such as delay, retry strategy, timeout, etc., can be configured in RetryPolicy
.
Trait Implementations§
source§impl Clone for DeliverySemantic
impl Clone for DeliverySemantic
source§fn clone(&self) -> DeliverySemantic
fn clone(&self) -> DeliverySemantic
Returns a copy 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 DeliverySemantic
impl Debug for DeliverySemantic
source§impl Default for DeliverySemantic
impl Default for DeliverySemantic
source§impl<'de> Deserialize<'de> for DeliverySemantic
impl<'de> Deserialize<'de> for DeliverySemantic
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Display for DeliverySemantic
impl Display for DeliverySemantic
source§impl FromStr for DeliverySemantic
impl FromStr for DeliverySemantic
source§impl Hash for DeliverySemantic
impl Hash for DeliverySemantic
source§impl PartialEq for DeliverySemantic
impl PartialEq for DeliverySemantic
source§fn eq(&self, other: &DeliverySemantic) -> bool
fn eq(&self, other: &DeliverySemantic) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for DeliverySemantic
impl Serialize for DeliverySemantic
impl Copy for DeliverySemantic
impl Eq for DeliverySemantic
impl StructuralPartialEq for DeliverySemantic
Auto Trait Implementations§
impl Freeze for DeliverySemantic
impl RefUnwindSafe for DeliverySemantic
impl Send for DeliverySemantic
impl Sync for DeliverySemantic
impl Unpin for DeliverySemantic
impl UnwindSafe for DeliverySemantic
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.