Enum nats::jetstream::DeliverPolicy

#[repr(u8)]
pub enum DeliverPolicy {
    All = 0,
    Last = 1,
    New = 2,
    ByStartSeq = 3,
    ByStartTime = 4,
    LastPerSubject = 5,
}

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

Variants

All = 0

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

Last = 1

Last will start the consumer with the last sequence received.

New = 2

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

ByStartSeq = 3

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

ByStartTime = 4

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

LastPerSubject = 5

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

This method tests for self and other values to be equal, and is used by ==.

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

This method 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