[−][src]Struct nakadi_types::model::event_type::Partition
Partition information. Can be helpful when trying to start a stream using an unmanaged API.
This information is not related to the state of the consumer clients.
See also Nakadi Manual
Fields
partition: PartitionId
oldest_available_offset: CursorOffset
An offset of the oldest available Event in that partition. This value will be changing upon removal of Events from the partition by the background archiving/cleanup mechanism.
newest_available_offset: CursorOffset
An offset of the newest available Event in that partition. This value will be changing upon reception of new events for this partition by Nakadi.
This value can be used to construct a cursor when opening streams (see GET /event-type/{name}/events for details).
Might assume the special name BEGIN, meaning a pointer to the offset of the oldest available event in the partition.
unconsumed_events: Option<u64>
Approximate number of events unconsumed by the client. This is also known as consumer lag and is used for monitoring purposes by consumers interested in keeping an eye on the number of unconsumed events.
If the event type uses ‘compact’ cleanup policy - then the actual number of unconsumed events in this partition can be lower than the one reported in this field.
Trait Implementations
impl Clone for Partition
[src]
impl Debug for Partition
[src]
impl<'de> Deserialize<'de> for Partition
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for Partition
[src]
Auto Trait Implementations
impl RefUnwindSafe for Partition
impl Send for Partition
impl Sync for Partition
impl Unpin for Partition
impl UnwindSafe for Partition
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: Deserialize<'de>,
[src]
T: Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,