Enum DeliverPolicy 

#[repr(u8)]
pub enum DeliverPolicy {
    All,
    Last,
    New,
    ByStartSequence {
        start_sequence: u64,
    },
    ByStartTime {
        start_time: OffsetDateTime,
    },
    LastPerSubject,
}

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.

ByStartSequence

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

Fields

start_sequence: u64

ByStartTime

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

Fields

start_time: OffsetDateTime

LastPerSubject

LastPerSubject will start the consumer with the last message for all subjects received.

Trait Implementations

impl Clone for DeliverPolicy

fn clone(&self) -> DeliverPolicy

Returns a duplicate of the value.

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<(), Error>

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<DeliverPolicy, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DeliverPolicy

impl PartialEq for DeliverPolicy

fn eq(&self, other: &DeliverPolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for DeliverPolicy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DeliverPolicy