Struct CostTrackerStream 

pub struct CostTrackerStream<P: Producer> { /* private fields */ }

Reports through an InventoryTracker, which hashes each ObjectId both to anonymize it and to decide whether it is sampled. See objectstore_inventory_tracker for the record format.

Logs, counts, and swallows errors returned by the InventoryTracker.

Implementations

impl<P: Producer> CostTrackerStream<P>

pub fn new(producer: P, config: &CostTrackerStreamConfig) -> Self

Reports changes through producer, as described by config.

Trait Implementations

impl<P> ChangeStream for CostTrackerStream<P>

where P: Producer + Clone + Send + Sync + 'static, P::Error: Into<BoxError> + Send + 'static,

fn write(&self, id: &ObjectId, size: u64, expires_at: Option<SystemTime>)

Reports that id now occupies size bytes. Used for new writes and overwrites.

fn update(&self, id: &ObjectId, expires_at: Option<SystemTime>)

Reports that id’s expiration moved, with its stored size unchanged.

fn delete(&self, id: &ObjectId)

Reports that id was deleted explicitly. Does not account for automatic GC.

fn join<'life0, 'async_trait>( &'life0 self, timeout: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Blocks until reported records have been delivered, or timeout elapses.

impl<P: Producer> Debug for CostTrackerStream<P>

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

Formats the value using the given formatter.