Enum DeliverPolicy 

pub enum DeliverPolicy {
    All,
    Last,
    New,
    ByStartSequence {
        sequence: u64,
    },
    ByStartTime {
        timestamp: u64,
    },
    LastPerSubject,
}

Delivery policy for subscriptions

Controls where a new consumer starts reading from the stream. Maps to provider-native delivery policies (e.g., NATS DeliverPolicy).

Variants

All

Deliver all available messages

Last

Deliver starting from the last message

New

Deliver only new messages published after subscription

ByStartSequence

Deliver starting from a specific sequence number

Fields

sequence: u64

ByStartTime

Deliver starting from a specific timestamp (Unix milliseconds)

Fields

timestamp: u64

LastPerSubject

Deliver the last message per subject

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

impl StructuralPartialEq for DeliverPolicy