Struct rdkafka::statistics::ExactlyOnceSemantics

source · [−]

pub struct ExactlyOnceSemantics {
    pub idemp_state: String,
    pub idemp_stateage: i64,
    pub txn_state: String,
    pub txn_stateage: i64,
    pub txn_may_enq: bool,
    pub producer_id: i64,
    pub producer_epoch: i64,
    pub epoch_cnt: i64,
}

Expand description

Exactly-once semantics statistics.

Fields

idemp_state: String

The current idempotent producer state.

idemp_stateage: i64

THe time elapsed since the last idempotent producer state change, in milliseconds.

txn_state: String

The current transactional producer state.

txn_stateage: i64

The time elapsed since the last transactional producer state change, in milliseconds.

txn_may_enq: bool

Whether the transactional state allows enqueing (producing) new messages.

producer_id: i64

The currently assigned producer ID, or -1.

producer_epoch: i64

The current epoch, or -1.

epoch_cnt: i64

The number of producer ID assignments.

Trait Implementations

impl Debug for ExactlyOnceSemantics

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

Formats the value using the given formatter. Read more

impl Default for ExactlyOnceSemantics

fn default() -> ExactlyOnceSemantics

Returns the “default value” for a type. Read more

impl<'de> Deserialize<'de> for ExactlyOnceSemantics

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

Deserialize this value from the given Serde deserializer. Read more

Auto Trait Implementations

impl RefUnwindSafe for ExactlyOnceSemantics

impl Send for ExactlyOnceSemantics

impl Sync for ExactlyOnceSemantics

impl Unpin for ExactlyOnceSemantics

impl UnwindSafe for ExactlyOnceSemantics

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Performs the conversion.

impl<T, U> Into<U> for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,