Struct CountersManager

pub struct CountersManager { /* private fields */ }

Implementations

impl CountersManager

pub fn new(metadata_buffer: AtomicBuffer, values_buffer: AtomicBuffer) -> Self

pub fn new_opt( metadata_buffer: AtomicBuffer, values_buffer: AtomicBuffer, clock: fn() -> u64, free_to_reuse_timeout_ms: u64, ) -> Self

pub fn iter(&self) -> CountersReaderIter<'_>

pub fn allocate_opt( &mut self, type_id: i32, key_opt: Option<&[u8]>, key_func: Option<impl Fn(&mut AtomicBuffer)>, label_rs: &str, ) -> Result<i32, AeronError>

This fn allocates counter with given type, key and label. The keys can be provided by two ways: 1. through key_opt param 2. could be generated and written in-place by key_func param If both key_opt and key_func are specified then AeronError is returned.

pub fn allocate(&mut self, label: &str) -> Result<i32, AeronError>

pub fn free(&mut self, counter_id: i32)

pub fn set_counter_value(&mut self, counter_id: i32, value: u64)

pub fn counter_value(&self, id: i32) -> Result<u64, AeronError>