Enum BackpressurePolicy 

pub enum BackpressurePolicy {
    DropOldest {
        queue_depth: usize,
    },
    DropNewest {
        queue_depth: usize,
    },
    Block {
        queue_depth: usize,
    },
}

Controls queue behavior between pipeline stages.

Applied to the bounded channel between the GStreamer decode thread and the stage execution thread.

Variants

DropOldest

Drop the oldest frame in the queue to make room for new ones.

This is the default — real-time perception prefers fresh frames over stale ones.

Fields

queue_depth: usize

Maximum number of frames in the queue.

DropNewest

Drop the incoming frame if the queue is full.

Fields

queue_depth: usize

Maximum number of frames in the queue.

Block

Block the producer until space is available.

Use with caution — can cause GStreamer buffer buildup.

Fields

queue_depth: usize

Maximum number of frames in the queue.

Implementations

impl BackpressurePolicy

pub fn queue_depth(&self) -> usize

Returns the configured queue depth.

Trait Implementations

impl Clone for BackpressurePolicy

fn clone(&self) -> BackpressurePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressurePolicy

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

Formats the value using the given formatter.

impl Default for BackpressurePolicy

fn default() -> Self

Returns the “default value” for a type.