Struct nakadi_types::model::subscription::CursorCommitResults

pub struct CursorCommitResults {
    pub commit_results: Vec<CursorCommitResult>,
}

The result of all cursor commits with the SubscriptionCursors themselves.

See also Nakadi Manual

Fields

commit_results: Vec<CursorCommitResult>

Methods

impl CursorCommitResults

pub fn all_committed(&self) -> bool

pub fn iter_committed_cursors(
    &self
) -> impl Iterator<Item = &SubscriptionCursor>

pub fn into_iter_committed_cursors(
    self
) -> impl Iterator<Item = SubscriptionCursor>

pub fn iter_outdated_cursors(&self) -> impl Iterator<Item = &SubscriptionCursor>

pub fn into_iter_outdated_cursors(
    self
) -> impl Iterator<Item = SubscriptionCursor>

pub fn into_inner(self) -> Vec<CursorCommitResult>

Trait Implementations

impl Clone for CursorCommitResults

fn clone(&self) -> CursorCommitResults

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CursorCommitResults

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Default for CursorCommitResults

fn default() -> CursorCommitResults

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for CursorCommitResults

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl From<CursorCommitResults> for Vec<CursorCommitResult>

fn from(v: CursorCommitResults) -> Self

Performs the conversion.

impl Serialize for CursorCommitResults

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.