Struct AeronArchiveRecordingDescriptorPoller

pub struct AeronArchiveRecordingDescriptorPoller { /* private fields */ }

Implementations

impl AeronArchiveRecordingDescriptorPoller

pub fn new_zeroed() -> Result<Self, AeronCError>

creates zeroed struct where the underlying c struct is on the heap

pub fn ctx(&self) -> AeronArchiveContext

pub fn subscription(&self) -> AeronSubscription

pub fn control_session_id(&self) -> i64

pub fn fragment_limit(&self) -> c_int

pub fn fragment_assembler(&self) -> AeronControlledFragmentAssembler

pub fn error_on_fragment(&self) -> bool

pub fn correlation_id(&self) -> i64

pub fn remaining_record_count(&self) -> i32

pub fn recording_descriptor_consumer( &self, ) -> aeron_archive_recording_descriptor_consumer_func_t

pub fn recording_descriptor_consumer_clientd(&self) -> *mut c_void

pub fn is_dispatch_complete(&self) -> bool

pub fn close(&self) -> Result<i32, AeronCError>

pub fn reset<AeronArchiveRecordingDescriptorConsumerFuncHandlerImpl: AeronArchiveRecordingDescriptorConsumerFuncCallback>( &self, correlation_id: i64, record_count: i32, recording_descriptor_consumer: Option<&Handler<AeronArchiveRecordingDescriptorConsumerFuncHandlerImpl>>, )

pub fn reset_once<AeronArchiveRecordingDescriptorConsumerFuncHandlerImpl: FnMut(AeronArchiveRecordingDescriptor)>( &self, correlation_id: i64, record_count: i32, recording_descriptor_consumer: AeronArchiveRecordingDescriptorConsumerFuncHandlerImpl, )

NOTE: aeron must not store this closure and instead use it immediately. If not you will get undefined behaviour, use with care

pub fn poll(&self) -> Result<i32, AeronCError>

pub fn get_inner(&self) -> *mut aeron_archive_recording_descriptor_poller_t

Trait Implementations

impl Clone for AeronArchiveRecordingDescriptorPoller

fn clone(&self) -> AeronArchiveRecordingDescriptorPoller

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AeronArchiveRecordingDescriptorPoller

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

Formats the value using the given formatter.

impl Deref for AeronArchiveRecordingDescriptorPoller

type Target = aeron_archive_recording_descriptor_poller_stct

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<&AeronArchiveRecordingDescriptorPoller> for *mut aeron_archive_recording_descriptor_poller_t

fn from(value: &AeronArchiveRecordingDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<*const aeron_archive_recording_descriptor_poller_stct> for AeronArchiveRecordingDescriptorPoller

fn from(value: *const aeron_archive_recording_descriptor_poller_t) -> Self

Converts to this type from the input type.

impl From<*mut aeron_archive_recording_descriptor_poller_stct> for AeronArchiveRecordingDescriptorPoller

fn from(value: *mut aeron_archive_recording_descriptor_poller_t) -> Self

Converts to this type from the input type.

impl From<AeronArchiveRecordingDescriptorPoller> for *mut aeron_archive_recording_descriptor_poller_t

fn from(value: AeronArchiveRecordingDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<AeronArchiveRecordingDescriptorPoller> for aeron_archive_recording_descriptor_poller_t

fn from(value: AeronArchiveRecordingDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<aeron_archive_recording_descriptor_poller_stct> for AeronArchiveRecordingDescriptorPoller

fn from(value: aeron_archive_recording_descriptor_poller_t) -> Self

Converts to this type from the input type.