Enum async_nats::jetstream::consumer::AckPolicy
source · #[repr(u8)]pub enum AckPolicy {
Explicit = 2,
None = 0,
All = 1,
}
Expand description
Determines whether messages will be acknowledged individually, in batches, or never.
Variants§
Explicit = 2
All messages will be individually acknowledged. This is the default.
None = 0
No messages are acknowledged.
All = 1
Acknowledges all messages with lower sequence numbers when a later message is acknowledged. Useful for “batching” acknowledgment.
Trait Implementations§
source§impl<'de> Deserialize<'de> for AckPolicy
impl<'de> Deserialize<'de> for AckPolicy
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
impl Copy for AckPolicy
impl Eq for AckPolicy
impl StructuralPartialEq for AckPolicy
Auto Trait Implementations§
impl Freeze for AckPolicy
impl RefUnwindSafe for AckPolicy
impl Send for AckPolicy
impl Sync for AckPolicy
impl Unpin for AckPolicy
impl UnwindSafe for AckPolicy
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,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)