Struct nakadi_types::subscription::SubscriptionCursor

pub struct SubscriptionCursor {
    pub cursor: Cursor,
    pub event_type: EventTypeName,
    pub cursor_token: CursorToken,
}

Cursor of a subscription with a CursorToken which is usually found within a SubscriptionEventStreamBatch.

See also Nakadi Manual

Fields

cursor: Cursor

event_type: EventTypeName

The name of the event type this partition’s events belong to.

cursor_token: CursorToken

An opaque value defined by the server.

Implementations

impl SubscriptionCursor

pub fn into_event_type_cursor(self) -> EventTypeCursor

pub fn into_event_type_cursor_begin(self) -> EventTypeCursor

Turns this into a EventTypeCursor that points to the begin of the subscription

pub fn into_event_type_partition(self) -> EventTypePartition

pub fn to_event_type_partition(&self) -> EventTypePartition

Trait Implementations

impl Clone for SubscriptionCursor

pub fn clone(&self) -> SubscriptionCursor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionCursor

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionCursor

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

Deserialize this value from the given Serde deserializer.

impl Eq for SubscriptionCursor

impl EventTypePartitionLike for SubscriptionCursor

pub fn event_type(&self) -> &EventTypeName

pub fn partition(&self) -> &PartitionId

impl From<SubscriptionCursor> for EventTypePartition

pub fn from(v: SubscriptionCursor) -> Self

Performs the conversion.

impl From<SubscriptionCursor> for EventTypeCursor

pub fn from(c: SubscriptionCursor) -> Self

Performs the conversion.

impl PartialEq<SubscriptionCursor> for SubscriptionCursor

pub fn eq(&self, other: &SubscriptionCursor) -> bool

This method tests for self and other values to be equal, and is used by ==.

pub fn ne(&self, other: &SubscriptionCursor) -> bool

This method tests for !=.

impl Serialize for SubscriptionCursor

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

Serialize this value into the given Serde serializer.

impl StructuralEq for SubscriptionCursor

impl StructuralPartialEq for SubscriptionCursor