pub enum SubscriptionStart {
NewOnly,
LastReceived,
AllAvailable,
FromSequence(u64),
FromTimestamp(SystemTime),
FromPast(Duration),
}
Expand description
List of possible starting positions for a new Subscription
Variants§
NewOnly
Only receive new messages, starting from now
LastReceived
Start receiving from the last received message (default)
AllAvailable
Send all available messages on the subject
FromSequence(u64)
Start at a given message sequence. You can use that to build your own durable queue
FromTimestamp(SystemTime)
Replay starting from a given timestamp (need to be in the past)
FromPast(Duration)
Replay from a duration in the past
Trait Implementations§
Source§impl Debug for SubscriptionStart
impl Debug for SubscriptionStart
Auto Trait Implementations§
impl Freeze for SubscriptionStart
impl RefUnwindSafe for SubscriptionStart
impl Send for SubscriptionStart
impl Sync for SubscriptionStart
impl Unpin for SubscriptionStart
impl UnwindSafe for SubscriptionStart
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more