Struct FinishedWindow 

pub struct FinishedWindow<K> { /* private fields */ }

A memory window for things that belong to finished orders: the cid maps of a connector.

A connector keeps small maps next to its OrderRuntime (cid to instrument, broker id to cid, …). When an order is final, the connector pushes its cid here. Whatever is older than the window, or beyond the count limit, comes back from expired, and the connector drops the entries of those cids. So the maps stay as big as a day of trading and not as the whole life of the process.

Examples

use std::time::{Duration, Instant};
use brokapi_runtime::FinishedWindow;

let mut window = FinishedWindow::with_limits(Duration::from_secs(60), 100);
let t0 = Instant::now();
window.push(t0, "a");
window.push(t0 + Duration::from_secs(30), "b");
assert!(window.expired(t0 + Duration::from_secs(59)).is_empty());
assert_eq!(window.expired(t0 + Duration::from_secs(61)), vec!["a"]);
assert_eq!(window.len(), 1);

Implementations

impl<K> FinishedWindow<K>

pub fn new() -> Self

A window of RETENTION and RETAINED_FINISHED.

pub fn with_limits(window: Duration, max: usize) -> Self

A window that keeps a key for window, and at most max keys.

pub fn push(&mut self, now: Instant, key: K)

Notes that the order key finished at now.

pub fn expired(&mut self, now: Instant) -> Vec<K>

Takes out the keys that are older than the window as of now, or beyond the count limit, oldest first. The caller drops what it kept for them.

pub fn len(&self) -> usize

How many keys are held.

pub fn is_empty(&self) -> bool

true when no key is held.

Trait Implementations

impl<K: Debug> Debug for FinishedWindow<K>

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

Formats the value using the given formatter.

impl<K> Default for FinishedWindow<K>

fn default() -> Self

Returns the “default value” for a type.