Enum async_nats::jetstream::consumer::ReplayPolicy
source · #[repr(u8)]pub enum ReplayPolicy {
Instant = 0,
Original = 1,
}
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 = 0
Sends all messages in a stream to the consumer as quickly as possible. This is the default.
Original = 1
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§
source§impl Clone for ReplayPolicy
impl Clone for ReplayPolicy
source§fn clone(&self) -> ReplayPolicy
fn clone(&self) -> ReplayPolicy
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 ReplayPolicy
impl Debug for ReplayPolicy
source§impl Default for ReplayPolicy
impl Default for ReplayPolicy
source§fn default() -> ReplayPolicy
fn default() -> ReplayPolicy
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for ReplayPolicy
impl<'de> Deserialize<'de> for ReplayPolicy
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 PartialEq for ReplayPolicy
impl PartialEq for ReplayPolicy
source§impl Serialize for ReplayPolicy
impl Serialize for ReplayPolicy
impl Copy for ReplayPolicy
impl Eq for ReplayPolicy
impl StructuralPartialEq for ReplayPolicy
Auto Trait Implementations§
impl Freeze for ReplayPolicy
impl RefUnwindSafe for ReplayPolicy
impl Send for ReplayPolicy
impl Sync for ReplayPolicy
impl Unpin for ReplayPolicy
impl UnwindSafe for ReplayPolicy
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
)