Module timely::dataflow::channels::pullers::counter

source ·
Expand description

A wrapper which accounts records pulled past in a shared count map.

Structs§

  • ConsumedGuard
    A guard type that updates the change batch counts on drop
  • Counter
    A wrapper which accounts records pulled past in a shared count map.