Enum nats::jetstream::DeliverPolicy

#[repr(u8)]
pub enum DeliverPolicy {
    All,
    Last,
    New,
    ByStartSeq,
    ByStartTime,
    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.

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.

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<DeliverPolicy> 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 !=.

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

impl StructuralPartialEq for DeliverPolicy