Enum nats::jetstream::DeliverPolicy

#[repr(u8)]pub enum DeliverPolicy {
    All,
    Last,
    New,
    ByStartSeq,
    ByStartTime,
}

DeliverPolicy determines how the consumer should select the first message to deliver.

Variants

All

All causes the consumer to receive the oldest messages still present in the system. This is the default.

Last

Last will start the consumer with the last sequence received.

New

New will only deliver new messages that are received by the JetStream server after the consumer is created.

ByStartSeq

ByStartSeq will look for a defined starting sequence to the consumer’s configured opt_start_seq parameter.

ByStartTime

ByStartTime will select the first messsage with a timestamp >= to the consumer’s configured opt_start_time parameter.

Trait Implementations

impl Clone for DeliverPolicy

fn clone(&self) -> DeliverPolicy

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for DeliverPolicy

impl Debug for DeliverPolicy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DeliverPolicy

fn default() -> DeliverPolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DeliverPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for DeliverPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.