Struct MsgQueue 

pub struct MsgQueue { /* private fields */ }

Ordered queue of owned messages.

Implementations

impl MsgQueue

pub fn new() -> Self

Build an empty queue.

Examples

use dynomite::msg::MsgQueue;
let q = MsgQueue::new();
assert!(q.is_empty());

pub fn with_capacity(n: usize) -> Self

Build an empty queue with capacity for at least n messages.

Examples

use dynomite::msg::MsgQueue;
let q = MsgQueue::with_capacity(8);
assert!(q.is_empty());

pub fn push_back(&mut self, msg: Msg)

Append msg to the tail of the queue.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(7, MsgType::ReqRedisGet, true));
assert_eq!(q.len(), 1);

pub fn push_front(&mut self, msg: Msg)

Push msg to the head of the queue.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_front(Msg::new(1, MsgType::ReqMcGet, true));
assert_eq!(q.len(), 1);

pub fn pop_front(&mut self) -> Option<Msg>

Remove and return the head of the queue.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(1, MsgType::ReqMcGet, true));
assert!(q.pop_front().is_some());
assert!(q.pop_front().is_none());

pub fn pop_back(&mut self) -> Option<Msg>

Remove and return the tail of the queue.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(1, MsgType::ReqMcGet, true));
q.push_back(Msg::new(2, MsgType::ReqMcGet, true));
assert_eq!(q.pop_back().unwrap().id(), 2);

pub fn len(&self) -> usize

Number of messages currently in the queue.

Examples

use dynomite::msg::MsgQueue;
assert_eq!(MsgQueue::new().len(), 0);

pub fn is_empty(&self) -> bool

True when the queue is empty.

Examples

use dynomite::msg::MsgQueue;
assert!(MsgQueue::new().is_empty());

pub fn front(&self) -> Option<&Msg>

Borrow the front message without removing it.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(42, MsgType::ReqRedisGet, true));
assert_eq!(q.front().unwrap().id(), 42);

pub fn front_mut(&mut self) -> Option<&mut Msg>

Mutably borrow the front message.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(1, MsgType::ReqRedisGet, true));
q.front_mut().unwrap().set_swallow(true);

pub fn iter(&self) -> Iter<'_, Msg>

Iterate over the queue in front-to-back order.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(1, MsgType::ReqRedisGet, true));
q.push_back(Msg::new(2, MsgType::ReqRedisSet, true));
let ids: Vec<u64> = q.iter().map(|m| m.id()).collect();
assert_eq!(ids, vec![1, 2]);

pub fn msg_get_id_lookup(&self, id: MsgId) -> Option<&Msg>

Find a message by id and return a shared reference.

This is the queue-side counterpart to the C dict_msg_id-shaped lookup that traverses the outstanding-msg list. Use crate::msg::index::MsgIndex when an O(1) lookup is required across many queues.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType};

let mut q = MsgQueue::new();
q.push_back(Msg::new(99, MsgType::ReqRedisGet, true));
assert!(q.msg_get_id_lookup(99).is_some());
assert!(q.msg_get_id_lookup(1).is_none());

Trait Implementations

impl Debug for MsgQueue

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

Formats the value using the given formatter.

impl Default for MsgQueue

fn default() -> MsgQueue

Returns the “default value” for a type.

impl<'a> IntoIterator for &'a MsgQueue

type Item = &'a Msg

The type of the elements being iterated over.

type IntoIter = Iter<'a, Msg>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.