pub struct AeronLossReporter { /* private fields */ }Implementations§
Source§impl AeronLossReporter
impl AeronLossReporter
pub fn new( buffer: *mut u8, next_record_offset: usize, capacity: usize, ) -> Result<Self, AeronCError>
Sourcepub fn new_zeroed_on_heap() -> Self
pub fn new_zeroed_on_heap() -> Self
creates zeroed struct where the underlying c struct is on the heap
Sourcepub fn new_zeroed_on_stack() -> Self
pub fn new_zeroed_on_stack() -> Self
creates zeroed struct where the underlying c struct is on the stack (Use with care)
pub fn buffer(&self) -> *mut u8
pub fn next_record_offset(&self) -> usize
pub fn capacity(&self) -> usize
pub fn init(&self, buffer: &mut [u8]) -> Result<i32, AeronCError>
pub fn create_entry( &self, initial_bytes_lost: i64, timestamp_ms: i64, session_id: i32, stream_id: i32, channel: &str, source: &str, ) -> aeron_loss_reporter_entry_offset_t
pub fn record_observation( &self, offset: aeron_loss_reporter_entry_offset_t, bytes_lost: i64, timestamp_ms: i64, )
pub fn resolve_filename( directory: &CStr, filename_buffer: &mut [u8], ) -> Result<i32, AeronCError>
pub fn read<AeronLossReporterReadEntryFuncHandlerImpl: AeronLossReporterReadEntryFuncCallback>( buffer: &[u8], entry_func: Option<&Handler<AeronLossReporterReadEntryFuncHandlerImpl>>, ) -> usize
Sourcepub fn read_fn<AeronLossReporterReadEntryFuncHandlerImpl: FnMut(i64, i64, i64, i64, i32, i32, &str, &str)>(
buffer: &[u8],
entry_func: AeronLossReporterReadEntryFuncHandlerImpl,
) -> usize
pub fn read_fn<AeronLossReporterReadEntryFuncHandlerImpl: FnMut(i64, i64, i64, i64, i32, i32, &str, &str)>( buffer: &[u8], entry_func: AeronLossReporterReadEntryFuncHandlerImpl, ) -> usize
Stack-borrowed closure (_fn variant): the FnMut closure lives on the
caller’s stack and is borrowed for this call only — the callback fires
synchronously inside the call, so nothing is heap-allocated, nothing is stored,
and the closure may borrow local state. Prefer this over the retained
Handler-based form on the hot path; only generated for callbacks the C
client does not retain (i.e. not stored for later firing).
§Panics
A panic inside the closure cannot unwind across the extern "C" callback
boundary and aborts the process (since Rust 1.81). Return early instead
of panicking in production fragment handlers.
pub fn get_inner(&self) -> *mut aeron_loss_reporter_t
Sourcepub unsafe fn get_inner_mut(&self) -> &mut aeron_loss_reporter_t
pub unsafe fn get_inner_mut(&self) -> &mut aeron_loss_reporter_t
Mutable access to the underlying C struct, minted from &self: nothing
prevents two live &mut at once, so the caller must ensure exclusive
access for the lifetime of the returned reference.
§Safety
No other reference (& or &mut) to the underlying struct may be
alive while the returned &mut is in use.
pub fn get_inner_ref(&self) -> &aeron_loss_reporter_t
Source§impl AeronLossReporter
impl AeronLossReporter
Sourcepub fn clone_struct(&self) -> Self
pub fn clone_struct(&self) -> Self
Regular clone just increases the reference count of underlying count.
clone_struct shallow copies the content of the underlying struct on heap.
NOTE: if the struct has references to other structs these will not be copied
Must be only used on structs which has no init/clean up methods. So its dangerous to use with Aeron/AeronContext/AeronPublication/AeronSubscription More intended for AeronArchiveRecordingDescriptor (note strings will not work as its a shallow copy)
Trait Implementations§
Source§impl Clone for AeronLossReporter
impl Clone for AeronLossReporter
Source§fn clone(&self) -> AeronLossReporter
fn clone(&self) -> AeronLossReporter
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for AeronLossReporter
impl Debug for AeronLossReporter
Source§impl Default for AeronLossReporter
This will create an instance where the struct is zeroed, use with care
impl Default for AeronLossReporter
This will create an instance where the struct is zeroed, use with care