Struct aeron_rs::concurrent::counters::CountersManager

pub struct CountersManager { /* fields omitted */ }

Methods

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>