#[non_exhaustive]pub struct ListSuspendedPage {
pub entries: Vec<SuspendedExecutionEntry>,
pub next_cursor: Option<ExecutionId>,
}Expand description
One cursor-paginated page of suspended executions.
Pagination is cursor-based (not offset/limit) so a Valkey backend
can resume a partition scan from the last seen execution id and a
future Postgres backend can do keyset pagination on
executions WHERE state='suspended'. The cursor is opaque to
callers: pass next_cursor back as the cursor argument to the
next EngineBackend::list_suspended call to fetch the next
page. None means the stream is exhausted.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.entries: Vec<SuspendedExecutionEntry>Entries on this page, ordered by ascending suspended_at_ms
(timeout order) with execution_id as a lex tiebreak.
next_cursor: Option<ExecutionId>Resume-point for the next page. None when no further
entries remain in the partition.
Implementations§
Source§impl ListSuspendedPage
impl ListSuspendedPage
Sourcepub fn new(
entries: Vec<SuspendedExecutionEntry>,
next_cursor: Option<ExecutionId>,
) -> Self
pub fn new( entries: Vec<SuspendedExecutionEntry>, next_cursor: Option<ExecutionId>, ) -> Self
Construct a new page. Preferred over direct field init for
#[non_exhaustive] forward-compat.
Trait Implementations§
Source§impl Clone for ListSuspendedPage
impl Clone for ListSuspendedPage
Source§fn clone(&self) -> ListSuspendedPage
fn clone(&self) -> ListSuspendedPage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ListSuspendedPage
impl Debug for ListSuspendedPage
Source§impl<'de> Deserialize<'de> for ListSuspendedPage
impl<'de> Deserialize<'de> for ListSuspendedPage
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for ListSuspendedPage
impl PartialEq for ListSuspendedPage
Source§impl Serialize for ListSuspendedPage
impl Serialize for ListSuspendedPage
impl Eq for ListSuspendedPage
impl StructuralPartialEq for ListSuspendedPage
Auto Trait Implementations§
impl Freeze for ListSuspendedPage
impl RefUnwindSafe for ListSuspendedPage
impl Send for ListSuspendedPage
impl Sync for ListSuspendedPage
impl Unpin for ListSuspendedPage
impl UnsafeUnpin for ListSuspendedPage
impl UnwindSafe for ListSuspendedPage
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