Struct RefreshBatch 

pub struct RefreshBatch {
    pub queue: VecDeque<RefreshQueueItem>,
    pub in_flight: usize,
    pub total: usize,
    pub completed: usize,
    pub in_flight_aliases: HashSet<String>,
}

State of a R batch refresh. None when no batch is active. Drives a windowed concurrency: at most MAX_PARALLEL listings are in flight at any time. Each ContainerListing event decrements in_flight and pops the next queued item; the batch ends when queue is empty and in_flight drops to zero.

Fields

queue: VecDeque<RefreshQueueItem>

in_flight: usize

total: usize

Total host count when the batch started. used for the Refreshing N/M progress readout in the status footer.

completed: usize

Hosts whose listing has already returned (success or error).

in_flight_aliases: HashSet<String>

Aliases that the batch has spawned but not yet seen complete. Listings whose alias is NOT in this set are non-batch traffic (host-list C, action-complete refresh, a-add) and must not touch the counters. Without this guard the in-flight counter gets corrupted whenever a parallel non-batch fetch completes during a R run.

Trait Implementations

impl Debug for RefreshBatch

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

Formats the value using the given formatter.

impl Default for RefreshBatch

fn default() -> RefreshBatch

Returns the “default value” for a type.