Enum nats::jetstream::RetentionPolicy [−][src]
#[repr(u8)] pub enum RetentionPolicy { Limits, Interest, WorkQueue, }
RetentionPolicy
determines how messages in a set are retained.
Variants
Limits
(default) means that messages are retained until any given limit is reached.
This could be one of mesages, bytes, or age.
Interest
specifies that when all known observables have acknowledged a message it can be removed.
WorkQueue
specifies that when the first worker or subscriber acknowledges the message it can be removed.
Trait Implementations
impl Clone for RetentionPolicy
[src]
impl Clone for RetentionPolicy
[src]fn clone(&self) -> RetentionPolicy
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for RetentionPolicy
[src]
impl Copy for RetentionPolicy
[src]impl Default for RetentionPolicy
[src]
impl Default for RetentionPolicy
[src]fn default() -> RetentionPolicy
[src]
impl<'de> Deserialize<'de> for RetentionPolicy
[src]
impl<'de> Deserialize<'de> for RetentionPolicy
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for RetentionPolicy
[src]
impl Serialize for RetentionPolicy
[src]Auto Trait Implementations
impl RefUnwindSafe for RetentionPolicy
impl RefUnwindSafe for RetentionPolicy
impl Send for RetentionPolicy
impl Send for RetentionPolicy
impl Sync for RetentionPolicy
impl Sync for RetentionPolicy
impl Unpin for RetentionPolicy
impl Unpin for RetentionPolicy
impl UnwindSafe for RetentionPolicy
impl UnwindSafe for RetentionPolicy
Blanket Implementations
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,