Enum nats::jetstream::ReplayPolicy
source · #[repr(u8)]
pub enum ReplayPolicy {
Instant,
Original,
}
Expand description
ReplayPolicy
controls whether messages are sent to a consumer
as quickly as possible or at the rate that they were originally received at.
Variants
Instant
Sends all messages in a stream to the consumer as quickly as possible. This is the default.
Original
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
sourceimpl Clone for ReplayPolicy
impl Clone for ReplayPolicy
sourcefn clone(&self) -> ReplayPolicy
fn clone(&self) -> ReplayPolicy
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceimpl Debug for ReplayPolicy
impl Debug for ReplayPolicy
sourceimpl Default for ReplayPolicy
impl Default for ReplayPolicy
sourcefn default() -> ReplayPolicy
fn default() -> ReplayPolicy
Returns the “default value” for a type. Read more
sourceimpl<'de> Deserialize<'de> for ReplayPolicy
impl<'de> Deserialize<'de> for ReplayPolicy
sourcefn 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
sourceimpl PartialEq<ReplayPolicy> for ReplayPolicy
impl PartialEq<ReplayPolicy> for ReplayPolicy
sourcefn eq(&self, other: &ReplayPolicy) -> bool
fn eq(&self, other: &ReplayPolicy) -> bool
sourceimpl Serialize for ReplayPolicy
impl Serialize for ReplayPolicy
impl Copy for ReplayPolicy
impl Eq for ReplayPolicy
impl StructuralEq for ReplayPolicy
impl StructuralPartialEq for ReplayPolicy
Auto Trait Implementations
impl RefUnwindSafe for ReplayPolicy
impl Send for ReplayPolicy
impl Sync for ReplayPolicy
impl Unpin for ReplayPolicy
impl UnwindSafe for ReplayPolicy
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more