Enum MemoryLimitPolicy 

pub enum MemoryLimitPolicy {
    FailImmediately,
    ProducerBlock,
}

Java parity: org.apache.pulsar.client.api.MemoryLimitPolicy.

Selects how the client behaves when the configured global publish memory budget is exhausted (see crate::ClientBuilder::memory_limit).

Variants

FailImmediately

Fail new sends immediately with an out of memory error. Mirrors Java MemoryLimitPolicy.FAIL_IMMEDIATELY (the Java default).

ProducerBlock

Block the producer’s send/sendAsync until enough room frees up. Mirrors Java MemoryLimitPolicy.PRODUCER_BLOCK.

Trait Implementations

impl Clone for MemoryLimitPolicy

fn clone(&self) -> MemoryLimitPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for MemoryLimitPolicy

impl Debug for MemoryLimitPolicy

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

Formats the value using the given formatter.

impl Eq for MemoryLimitPolicy

impl From<MemoryLimitPolicy> for MemoryLimitPolicy

fn from(policy: MemoryLimitPolicy) -> Self

Converts to this type from the input type.

impl PartialEq for MemoryLimitPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for MemoryLimitPolicy