Enum nakadi_types::partition::CursorOffset

pub enum CursorOffset {
    Begin,
    N(String),
}

Offset of the event being pointed to.

Note that if you want to specify beginning position of a stream with first event at offset N, you should specify offset N-1. This applies in cases when you create new subscription or reset subscription offsets. Also for stream start offsets one can use special value:

begin - read from the oldest available event.

See also Nakadi Manual

Variants

Begin

N(String)

Implementations

impl CursorOffset

pub fn new<T: AsRef<str>>(offset: T) -> Self

pub fn as_str(&self) -> &str

Trait Implementations

impl Clone for CursorOffset

pub fn clone(&self) -> CursorOffset

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CursorOffset

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CursorOffset

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

Deserialize this value from the given Serde deserializer.

impl Display for CursorOffset

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

Formats the value using the given formatter.

impl Eq for CursorOffset

impl FromStr for CursorOffset

type Err = Error

The associated error which can be returned from parsing.

pub fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl PartialEq<CursorOffset> for CursorOffset

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

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

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

This method tests for !=.

impl Serialize for CursorOffset

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 CursorOffset

impl StructuralPartialEq for CursorOffset