arcon_state 0.2.1

State management features for Arcon
Documentation
use metrics::counter;

#[inline]
pub fn record_bytes_written(handle_name: &str, total_bytes: u64, backend_name: &str) {
    counter!(format!("{}_bytes_written", handle_name), total_bytes, "backend" => backend_name.to_string());
}

#[inline]
pub fn record_bytes_read(handle_name: &str, total_bytes: u64, backend_name: &str) {
    counter!(format!("{}_bytes_read", handle_name), total_bytes, "backend" => backend_name.to_string());
}