Enum BackpressureSchemaStrategy 

pub enum BackpressureSchemaStrategy {
    Block,
    DropOldest,
    DropNewest,
    Buffer,
}

Backpressure strategy for streaming output.

Variants

Block

Block until space is available in the buffer.

DropOldest

Drop oldest items when buffer is full.

DropNewest

Drop newest items when buffer is full.

Buffer

Buffer overflow items up to a limit, then block.

Trait Implementations

impl Clone for BackpressureSchemaStrategy

fn clone(&self) -> BackpressureSchemaStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BackpressureSchemaStrategy

impl Debug for BackpressureSchemaStrategy

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

Formats the value using the given formatter.

impl Default for BackpressureSchemaStrategy

fn default() -> BackpressureSchemaStrategy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BackpressureSchemaStrategy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BackpressureSchemaStrategy

impl PartialEq for BackpressureSchemaStrategy

fn eq(&self, other: &BackpressureSchemaStrategy) -> 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 BackpressureSchemaStrategy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BackpressureSchemaStrategy