rusty_cat/transfer_snapshot.rs
1use crate::direction::Direction;
2
3/// Lightweight runtime snapshot for monitoring current scheduler state.
4#[derive(Debug, Clone)]
5pub struct TransferSnapshot {
6 /// Number of queued transfer groups waiting to run.
7 ///
8 /// Range: `>= 0`.
9 pub queued_groups: usize,
10 /// Number of active transfer groups currently running.
11 ///
12 /// Range: `>= 0`.
13 pub active_groups: usize,
14 /// Keys of active groups as `(direction, dedup_key)`.
15 pub active_keys: Vec<(Direction, String)>,
16}