Enum QueueOverflowPolicy 

pub enum QueueOverflowPolicy {
    DropOldest,
    DropNewest,
    Block {
        timeout: Duration,
    },
}

Queue overflow handling policy

Determines how the queue behaves when it reaches capacity.

Default

The default policy is DropOldest, which is suitable for real-time monitoring scenarios where the latest data is most important.

Example

use canlink_hal::queue::QueueOverflowPolicy;
use std::time::Duration;

// Default policy
let policy = QueueOverflowPolicy::default();
assert!(matches!(policy, QueueOverflowPolicy::DropOldest));

// Block with timeout
let policy = QueueOverflowPolicy::Block {
    timeout: Duration::from_millis(100),
};

Variants

DropOldest

Drop the oldest message in the queue

This is the default policy, suitable for real-time monitoring where the latest data is most important.

DropNewest

Drop the newest message (the one being added)

Suitable for data recording scenarios where preserving complete history is important.

Block

Block until space is available or timeout expires

Suitable for critical messages that should not be lost. Returns QueueError::QueueFull if timeout expires.

Fields

timeout: Duration

Maximum time to wait for space

Implementations

impl QueueOverflowPolicy

pub fn drop_oldest() -> Self

Create a new DropOldest policy

pub fn drop_newest() -> Self

Create a new DropNewest policy

pub fn block(timeout: Duration) -> Self

Create a new Block policy with the given timeout

pub fn may_block(&self) -> bool

Check if this policy may block

pub fn timeout(&self) -> Option<Duration>

Get the timeout if this is a Block policy

Trait Implementations

impl Clone for QueueOverflowPolicy

fn clone(&self) -> QueueOverflowPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueOverflowPolicy

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

Formats the value using the given formatter.

impl Default for QueueOverflowPolicy

fn default() -> QueueOverflowPolicy

Returns the “default value” for a type.

impl PartialEq for QueueOverflowPolicy

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

impl Eq for QueueOverflowPolicy

impl StructuralPartialEq for QueueOverflowPolicy