Enum async_nats::jetstream::consumer::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 copy of the value.

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

Performs copy-assignment from source.

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 PartialEq for DeliverPolicy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

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.

impl Copy for DeliverPolicy

impl Eq for DeliverPolicy

impl StructuralPartialEq for DeliverPolicy