Struct fluvio_stream_model::epoch::DualEpochCounter

pub struct DualEpochCounter<T> { /* private fields */ }

Keep track of internal changes to object Track 3 different changes (spec,status,meta)

Implementations

impl<T> DualEpochCounter<T>

pub fn new(inner: T) -> Self

pub fn spec_epoch(&self) -> Epoch

pub fn status_epoch(&self) -> Epoch

pub fn meta_epoch(&self) -> Epoch

pub fn inner(&self) -> &T

pub fn inner_mut(&mut self) -> &mut T

pub fn inner_owned(self) -> T

Trait Implementations

impl<T: Clone> Clone for DualEpochCounter<T>

fn clone(&self) -> DualEpochCounter<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DualEpochCounter<T>

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

Formats the value using the given formatter.

impl<T: Default> Default for DualEpochCounter<T>

fn default() -> DualEpochCounter<T>

Returns the “default value” for a type.

impl<T> Deref for DualEpochCounter<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for DualEpochCounter<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T> From<T> for DualEpochCounter<T>

fn from(inner: T) -> Self

Converts to this type from the input type.