Enum IsolationLevel 

pub enum IsolationLevel {
    ReadUncommitted,
    ReadCommitted,
}

Consumer isolation level

Controls whether consumers can see uncommitted transactional messages.

Variants

ReadUncommitted

Read all messages, including those from aborted transactions. This is the default for backward compatibility.

ReadCommitted

Only read messages from committed transactions. Messages from aborted transactions are filtered out.

Implementations

impl IsolationLevel

pub fn as_str(&self) -> &'static str

Convert to string (Kafka-compatible)

pub fn from_u8(value: u8) -> Self

Convert from u8 (wire protocol) 0 = read_uncommitted (default) 1 = read_committed Other values default to read_uncommitted

pub fn as_u8(&self) -> u8

Convert to u8 (wire protocol)

Trait Implementations

impl Clone for IsolationLevel

fn clone(&self) -> IsolationLevel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IsolationLevel

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

Formats the value using the given formatter.

impl Default for IsolationLevel

fn default() -> IsolationLevel

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for IsolationLevel

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for IsolationLevel

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

Formats the value using the given formatter.

impl FromStr for IsolationLevel

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

Parse from string (Kafka-compatible)

type Err = String

The associated error which can be returned from parsing.

impl PartialEq for IsolationLevel

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for IsolationLevel

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for IsolationLevel

impl Eq for IsolationLevel

impl StructuralPartialEq for IsolationLevel