Struct OrderQueue 

pub struct OrderQueue { /* private fields */ }

A thread-safe queue of orders with specialized operations

Implementations

impl OrderQueue

pub fn new() -> Self

Create a new empty order queue

pub fn push(&self, order: Arc<OrderType<()>>)

Add an order to the queue

pub fn pop(&self) -> Option<Arc<OrderType<()>>>

Attempt to pop an order from the queue

pub fn find(&self, order_id: OrderId) -> Option<Arc<OrderType<()>>>

Search for an order with the given ID. O(1) operation.

pub fn remove(&self, order_id: OrderId) -> Option<Arc<OrderType<()>>>

Remove an order with the given ID Returns the removed order if found. O(1) for the map, but the ID remains in the queue.

pub fn to_vec(&self) -> Vec<Arc<OrderType<()>>>

Convert the queue to a vector (for snapshots)

pub fn from_vec(orders: Vec<Arc<OrderType<()>>>) -> Self

Creates a new OrderQueue instance and populates it with orders from the provided vector.

This function takes ownership of a vector of order references (wrapped in Arc) and constructs a new OrderQueue by iteratively pushing each order into the queue. The resulting queue maintains the insertion order of the original vector.

Parameters

• orders - A vector of atomic reference counted (Arc) order instances representing the orders to be added to the new queue.

Returns

A new OrderQueue instance containing all the orders from the input vector.

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn len(&self) -> usize

Returns the number of orders currently in the queue.

Returns

• usize - The total count of orders in the queue.

Trait Implementations

impl Debug for OrderQueue

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

Formats the value using the given formatter.

impl Default for OrderQueue

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OrderQueue

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for OrderQueue

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

Formats the value using the given formatter.

impl From<OrderQueue> for Vec<Arc<OrderType<()>>>

fn from(queue: OrderQueue) -> Self

Converts to this type from the input type.

impl From<Vec<Arc<OrderType<()>>>> for OrderQueue

fn from(orders: Vec<Arc<OrderType<()>>>) -> Self

Converts to this type from the input type.

impl FromStr for OrderQueue

type Err = PriceLevelError

The associated error which can be returned from parsing.

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

Parses a string s to return a value of this type.

impl Serialize for OrderQueue

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.