Enum nats::jetstream::ReplayPolicy [−][src]
#[repr(u8)] pub enum ReplayPolicy { Instant, Original, }
ReplayPolicy
controls whether messages are sent to a consumer
as quickly as possible or at the rate that they were originally received at.
Variants
Sends all messages in a stream to the consumer as quickly as possible. This is the default.
Sends messages to a consumer in a rate-limited fashion based on the rate of receipt. This is useful for replaying traffic in a testing or staging environment based on production traffic patterns.
Trait Implementations
impl Clone for ReplayPolicy
[src]
impl Clone for ReplayPolicy
[src]fn clone(&self) -> ReplayPolicy
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for ReplayPolicy
[src]
impl Copy for ReplayPolicy
[src]impl Default for ReplayPolicy
[src]
impl Default for ReplayPolicy
[src]fn default() -> ReplayPolicy
[src]
impl<'de> Deserialize<'de> for ReplayPolicy
[src]
impl<'de> Deserialize<'de> for ReplayPolicy
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for ReplayPolicy
[src]
impl Serialize for ReplayPolicy
[src]Auto Trait Implementations
impl RefUnwindSafe for ReplayPolicy
impl RefUnwindSafe for ReplayPolicy
impl Send for ReplayPolicy
impl Send for ReplayPolicy
impl Sync for ReplayPolicy
impl Sync for ReplayPolicy
impl Unpin for ReplayPolicy
impl Unpin for ReplayPolicy
impl UnwindSafe for ReplayPolicy
impl UnwindSafe for ReplayPolicy
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>,