Struct Aeron 

pub struct Aeron { /* private fields */ }

Implementations

impl Aeron

pub fn async_add_counter( &self, type_id: i32, key_buffer: &[u8], label_buffer: &str, ) -> Result<AeronAsyncAddCounter, AeronCError>

impl Aeron

pub fn add_counter( &self, type_id: i32, key_buffer: &[u8], label_buffer: &str, timeout: Duration, ) -> Result<AeronCounter, AeronCError>

impl Aeron

pub fn async_add_exclusive_publication( &self, uri: &CStr, stream_id: i32, ) -> Result<AeronAsyncAddExclusivePublication, AeronCError>

impl Aeron

pub fn add_exclusive_publication( &self, uri: &CStr, stream_id: i32, timeout: Duration, ) -> Result<AeronExclusivePublication, AeronCError>

impl Aeron

pub fn async_add_publication( &self, uri: &CStr, stream_id: i32, ) -> Result<AeronAsyncAddPublication, AeronCError>

impl Aeron

pub fn add_publication( &self, uri: &CStr, stream_id: i32, timeout: Duration, ) -> Result<AeronPublication, AeronCError>

impl Aeron

pub fn async_add_subscription<AeronAvailableImageHandlerImpl: AeronAvailableImageCallback, AeronUnavailableImageHandlerImpl: AeronUnavailableImageCallback>( &self, uri: &CStr, stream_id: i32, on_available_image_handler: Option<&Handler<AeronAvailableImageHandlerImpl>>, on_unavailable_image_handler: Option<&Handler<AeronUnavailableImageHandlerImpl>>, ) -> Result<AeronAsyncAddSubscription, AeronCError>

impl Aeron

pub fn add_subscription<AeronAvailableImageHandlerImpl: AeronAvailableImageCallback, AeronUnavailableImageHandlerImpl: AeronUnavailableImageCallback>( &self, uri: &CStr, stream_id: i32, on_available_image_handler: Option<&Handler<AeronAvailableImageHandlerImpl>>, on_unavailable_image_handler: Option<&Handler<AeronUnavailableImageHandlerImpl>>, timeout: Duration, ) -> Result<AeronSubscription, AeronCError>

impl Aeron

pub fn new(context: &AeronContext) -> Result<Self, AeronCError>

Create a Aeron client struct and initialize from the AeronContext struct.

The given AeronContext struct will be used exclusively by the client. Do not reuse between clients.

Parameters

• context to use for initialization.

Return

0 for success and -1 for error.

pub fn free(ptr: *mut c_void)

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

Start an Aeron. This may spawn a thread for the Client Conductor.

Return

0 for success and -1 for error.

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

Call the Conductor main do_work duty cycle once.

Client must have been created with use conductor invoker set to true.

Return

0 for success and -1 for error.

pub fn main_idle_strategy(&self, work_count: c_int)

Call the Conductor Idle Strategy.

Parameters

• work_count to pass to idle strategy.

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

Close and delete Aeron struct.

Return

0 for success and -1 for error.

pub fn is_closed(&self) -> bool

Determines if the client has been closed, e.g. via a driver timeout. Don’t call this method after calling aeron_close as that will have already freed the associated memory.

Return

true if it has been closed, false otherwise.

pub fn print_counters( &self, stream_out: Option<unsafe extern "C" fn(arg1: *const c_char)>, )

Call stream_out to print the counter labels and values.

Parameters

• stream_out to call for each label and value.

pub fn context(&self) -> AeronContext

Return the AeronContext that is in use by the given client.

Return

the AeronContext for the given client or NULL for an error.

pub fn client_id(&self) -> i64

Return the client id in use by the client.

Return

id value or -1 for an error.

pub fn next_correlation_id(&self) -> i64

Return a unique correlation id from the driver.

Return

unique correlation id or -1 for an error.

pub fn async_add_publication_cancel( &self, async_: &AeronAsyncAddPublication, ) -> Result<i32, AeronCError>

Cancel an in-progress aeron_async_add_publication operation.

Will eventually free the given AeronAsyncAddPublication instance. If a publication gets created by the time cancellation happens, it will get removed.

Note: The above guarantees only apply when a call to this method succeeds, i.e. return value is zero. If a return value is non-zero the operation won’t be canceled and the AeronAsyncAddPublication instance won’t be freed.

Return

0 for success or -1 for error.

pub fn async_remove_publication<AeronNotificationHandlerImpl: AeronNotificationCallback>( &self, registration_id: i64, on_complete: Option<&Handler<AeronNotificationHandlerImpl>>, ) -> Result<i32, AeronCError>

Asynchronously remove a publication. If there is an AeronPublication object for that publication, it will get closed and freed.

Parameters

• registration_id of the publication to be removed.

• on_complete optional callback to execute once the publication has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

pub fn async_remove_publication_once<AeronNotificationHandlerImpl: FnMut()>( &self, registration_id: i64, on_complete: AeronNotificationHandlerImpl, ) -> Result<i32, AeronCError>

Asynchronously remove a publication. If there is an AeronPublication object for that publication, it will get closed and freed.

Parameters

• registration_id of the publication to be removed.

• on_complete optional callback to execute once the publication has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

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

pub fn async_add_exclusive_publication_cancel( &self, async_: &AeronAsyncAddExclusivePublication, ) -> Result<i32, AeronCError>

Cancel an in-progress aeron_async_add_exclusive_publication operation.

Will eventually free the given AeronAsyncAddExclusivePublication instance. If a publication gets created by the time cancellation happens, it will get removed.

Note: The above guarantees only apply when a call to this method succeeds, i.e. return value is zero. If a return value is non-zero the operation won’t be canceled and the AeronAsyncAddExclusivePublication instance won’t be freed.

Return

0 for success or -1 for error.

pub fn async_remove_exclusive_publication<AeronNotificationHandlerImpl: AeronNotificationCallback>( &self, registration_id: i64, on_complete: Option<&Handler<AeronNotificationHandlerImpl>>, ) -> Result<i32, AeronCError>

Asynchronously remove an exclusive publication. If there is an AeronExclusivePublication object for that publication, it will get closed and freed.

Parameters

• registration_id of the exclusive publication to be removed.

• on_complete optional callback to execute once the exclusive publication has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

pub fn async_remove_exclusive_publication_once<AeronNotificationHandlerImpl: FnMut()>( &self, registration_id: i64, on_complete: AeronNotificationHandlerImpl, ) -> Result<i32, AeronCError>

Asynchronously remove an exclusive publication. If there is an AeronExclusivePublication object for that publication, it will get closed and freed.

Parameters

• registration_id of the exclusive publication to be removed.

• on_complete optional callback to execute once the exclusive publication has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

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

pub fn async_add_subscription_cancel( &self, async_: &AeronAsyncAddSubscription, ) -> Result<i32, AeronCError>

Cancel an in-progress aeron_async_add_subscription operation.

Will eventually free the given AeronAsyncAddSubscription instance. If a subscription gets created by the time cancellation happens, it will get removed.

Note: The above guarantees only apply when a call to this method succeeds, i.e. return value is zero. If a return value is non-zero the operation won’t be canceled and the AeronAsyncAddSubscription instance won’t be freed.

Return

0 for success or -1 for error.

pub fn async_remove_subscription<AeronNotificationHandlerImpl: AeronNotificationCallback>( &self, registration_id: i64, on_complete: Option<&Handler<AeronNotificationHandlerImpl>>, ) -> Result<i32, AeronCError>

Asynchronously remove a subscription. If there is an AeronSubscription object for that subscription, it will get closed and freed.

Parameters

• registration_id of the subscription to be removed.

• on_complete optional callback to execute once the subscription has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

pub fn async_remove_subscription_once<AeronNotificationHandlerImpl: FnMut()>( &self, registration_id: i64, on_complete: AeronNotificationHandlerImpl, ) -> Result<i32, AeronCError>

Asynchronously remove a subscription. If there is an AeronSubscription object for that subscription, it will get closed and freed.

Parameters

• registration_id of the subscription to be removed.

• on_complete optional callback to execute once the subscription has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

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

pub fn counters_reader(&self) -> AeronCountersReader

Return a reference to the counters reader of the given client.

The AeronCountersReader is maintained by the client. And should not be freed.

Return

AeronCountersReader or NULL for error.

pub fn async_add_counter_cancel( &self, async_: &AeronAsyncAddCounter, ) -> Result<i32, AeronCError>

Cancel an in-progress aeron_async_add_counter operation. Not applicable to aeron_async_add_static_counter, i.e. attempt to cancel static counter will fail with an error.

Will eventually free the given AeronAsyncAddCounter instance. If a counter gets created by the time cancellation happens, it will get removed.

Note: The above guarantees only apply when a call to this method succeeds, i.e. return value is zero. If a return value is non-zero the operation won’t be canceled and the AeronAsyncAddCounter instance won’t be freed.

Return

0 for success or -1 for error.

pub fn async_remove_counter<AeronNotificationHandlerImpl: AeronNotificationCallback>( &self, registration_id: i64, on_complete: Option<&Handler<AeronNotificationHandlerImpl>>, ) -> Result<i32, AeronCError>

Asynchronously remove a counter. Not applicable to static counters. If there is an AeronCounter object for that counter, it will get closed and freed.

Parameters

• registration_id of the counter to be removed.

• on_complete optional callback to execute once the counter has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

pub fn async_remove_counter_once<AeronNotificationHandlerImpl: FnMut()>( &self, registration_id: i64, on_complete: AeronNotificationHandlerImpl, ) -> Result<i32, AeronCError>

Asynchronously remove a counter. Not applicable to static counters. If there is an AeronCounter object for that counter, it will get closed and freed.

Parameters

• registration_id of the counter to be removed.

• on_complete optional callback to execute once the counter has been removed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime. Use NULL if not needed.

• on_complete_clientd parameter to pass to the on_complete callback.

Return

0 for success or -1 for error.

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

pub fn add_available_counter_handler( &self, pair: &AeronAvailableCounterPair, ) -> Result<i32, AeronCError>

Add a handler to be called when a new counter becomes available.

NOTE: This function blocks until the handler is added by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn remove_available_counter_handler( &self, pair: &AeronAvailableCounterPair, ) -> Result<i32, AeronCError>

Remove a previously added handler to be called when a new counter becomes available.

NOTE: This function blocks until the handler is removed by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn add_unavailable_counter_handler( &self, pair: &AeronUnavailableCounterPair, ) -> Result<i32, AeronCError>

Add a handler to be called when a new counter becomes unavailable or goes away.

NOTE: This function blocks until the handler is added by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn remove_unavailable_counter_handler( &self, pair: &AeronUnavailableCounterPair, ) -> Result<i32, AeronCError>

Remove a previously added handler to be called when a new counter becomes unavailable or goes away.

NOTE: This function blocks until the handler is removed by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn add_close_handler( &self, pair: &AeronCloseClientPair, ) -> Result<i32, AeronCError>

Add a handler to be called when client is closed.

NOTE: This function blocks until the handler is added by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn remove_close_handler( &self, pair: &AeronCloseClientPair, ) -> Result<i32, AeronCError>

Remove a previously added handler to be called when client is closed.

NOTE: This function blocks until the handler is removed by the client conductor thread.

Parameters

• pair holding the handler to call and a clientd to pass when called.

Return

0 for success and -1 for error

pub fn version_full() -> &'static str

Return full version and build string.

Return

full version and build string. SAFETY: this is static for performance reasons, so you should not store this without copying it!!

pub fn version_text() -> &'static str

Return version text.

Return

version text. SAFETY: this is static for performance reasons, so you should not store this without copying it!!

pub fn version_major() -> Result<i32, AeronCError>

Return major version number.

Return

major version number.

pub fn version_minor() -> Result<i32, AeronCError>

Return minor version number.

Return

minor version number.

pub fn version_patch() -> Result<i32, AeronCError>

Return patch version number.

Return

patch version number.

pub fn version_gitsha() -> &'static str

Return the git sha for the current build.

Return

git version SAFETY: this is static for performance reasons, so you should not store this without copying it!!

pub fn nano_clock() -> i64

Return time in nanoseconds for machine. Is not wall clock time.

Return

nanoseconds since epoch for machine.

pub fn epoch_clock() -> i64

Return time in milliseconds since epoch. Is wall clock time.

Return

milliseconds since epoch.

pub fn is_driver_active( dirname: &CStr, timeout_ms: i64, log_func: aeron_log_func_t, ) -> bool

Determine if an aeron driver is using a given aeron directory.

Parameters

• dirname for aeron directory

• timeout_ms to use to determine activity for aeron directory

• log_func to call during activity check to log diagnostic information.

Return

true for active driver or false for no active driver.

pub fn properties_buffer_load(buffer: &CStr) -> Result<i32, AeronCError>

Load properties from a string containing name=value pairs and set appropriate environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

Parameters

• buffer containing properties and values.

Return

0 for success and -1 for error.

pub fn properties_file_load(filename: &CStr) -> Result<i32, AeronCError>

Load properties file and set appropriate environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

Parameters

• filename to load.

Return

0 for success and -1 for error.

pub fn properties_http_load(url: &CStr) -> Result<i32, AeronCError>

Load properties from HTTP URL and set environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

Parameters

• url to attempt to retrieve and load.

Return

0 for success and -1 for error.

pub fn properties_load(url_or_filename: &CStr) -> Result<i32, AeronCError>

Load properties based on URL or filename. If string contains file or http URL, it will attempt to load properties from a file or http as indicated. If not a URL, then it will try to load the string as a filename.

Parameters

• url_or_filename to load properties from.

Return

0 for success and -1 for error.

pub fn errcode() -> Result<i32, AeronCError>

Return current aeron error code (errno) for calling thread.

Return

aeron error code for calling thread.

pub fn errmsg() -> &'static str

Return the current aeron error message for calling thread.

Return

aeron error message for calling thread. SAFETY: this is static for performance reasons, so you should not store this without copying it!!

pub fn default_path( path: *mut c_char, path_length: usize, ) -> Result<i32, AeronCError>

Get the default path used by the Aeron media driver.

Parameters

• path buffer to store the path.

• path_length space available in the buffer

Return

-1 if there is an issue or the number of bytes written to path excluding the terminator \0. If this is equal to or greater than the path_length then the path has been truncated.

pub fn randomised_int32() -> i32

pub fn thread_set_name(name: &CStr) -> Result<i32, AeronCError>

pub fn thread_get_name( name_buf: *mut c_char, name_buf_size: usize, ) -> Result<i32, AeronCError>

pub fn nano_sleep(nanoseconds: u64)

pub fn micro_sleep(microseconds: c_uint)

pub fn thread_set_affinity( name: &CStr, cpu_affinity_no: u8, ) -> Result<i32, AeronCError>

pub fn mutex_init(mutex: *mut aeron_mutex_t) -> Result<i32, AeronCError>

pub fn mutex_destroy(mutex: *mut aeron_mutex_t) -> Result<i32, AeronCError>

pub fn mutex_lock(mutex: *mut aeron_mutex_t) -> Result<i32, AeronCError>

pub fn mutex_unlock(mutex: *mut aeron_mutex_t) -> Result<i32, AeronCError>

pub fn semantic_version_compose(major: u8, minor: u8, patch: u8) -> i32

pub fn semantic_version_major(version: i32) -> u8

pub fn semantic_version_minor(version: i32) -> u8

pub fn semantic_version_patch(version: i32) -> u8

pub fn delete_directory(dirname: &CStr) -> Result<i32, AeronCError>

Delete the given aeron directory.

Parameters

• dirname to delete.

Return

0 for success and -1 for error.

pub fn set_thread_affinity_on_start(state: *mut c_void, role_name: &CStr)

Affinity setting function that complies with the aeron_agent_on_start_func_t structure that can be used as an agent start function. The state should be the AeronDriverContext* and the function will match the values “conductor”, “sender”, “receiver” and use the respective configuration options from the AeronDriverContext.

Parameters

• state client information passed to function, should be the AeronDriverContext*.

• role_name name of the role specified on the agent.

pub fn set_socket_non_blocking(fd: aeron_socket_t) -> Result<i32, AeronCError>

pub fn socket(domain: c_int, type_: c_int, protocol: c_int) -> aeron_socket_t

pub fn close_socket(socket: aeron_socket_t)

pub fn connect( fd: aeron_socket_t, address: &Sockaddr, address_length: socklen_t, ) -> Result<i32, AeronCError>

pub fn bind( fd: aeron_socket_t, address: &Sockaddr, address_length: socklen_t, ) -> Result<i32, AeronCError>

pub fn net_init() -> Result<i32, AeronCError>

pub fn getsockopt( fd: aeron_socket_t, level: c_int, optname: c_int, optval: *mut c_void, optlen: *mut socklen_t, ) -> Result<i32, AeronCError>

pub fn setsockopt( fd: aeron_socket_t, level: c_int, optname: c_int, optval: *const c_void, optlen: socklen_t, ) -> Result<i32, AeronCError>

pub fn sendmsg(fd: aeron_socket_t, msghdr: &Msghdr, flags: c_int) -> isize

pub fn send( fd: aeron_socket_t, buf: *const c_void, len: usize, flags: c_int, ) -> isize

pub fn recvmsg(fd: aeron_socket_t, msghdr: &Msghdr, flags: c_int) -> isize

pub fn res_header_entry_length( res: *mut c_void, remaining: usize, ) -> Result<i32, AeronCError>

pub fn logbuffer_check_term_length(term_length: u64) -> Result<i32, AeronCError>

pub fn logbuffer_check_page_size(page_size: u64) -> Result<i32, AeronCError>

pub fn is_directory(path: &CStr) -> Result<i32, AeronCError>

pub fn mkdir_recursive( pathname: &CStr, permission: c_int, ) -> Result<i32, AeronCError>

pub fn msync(addr: *mut c_void, length: usize) -> Result<i32, AeronCError>

pub fn delete_file(path: &CStr) -> Result<i32, AeronCError>

pub fn file_length(path: &CStr) -> i64

pub fn usable_fs_space(path: &CStr) -> u64

pub fn usable_fs_space_disabled(path: &CStr) -> u64

pub fn temp_filename(filename: *mut c_char, length: usize) -> usize

pub fn file_resolve( parent: &CStr, child: &CStr, buffer: *mut c_char, buffer_len: usize, ) -> Result<i32, AeronCError>

pub fn flow_control_parse_tagged_options( options_length: usize, options: &CStr, flow_control_options: &AeronFlowControlTaggedOptions, ) -> Result<i32, AeronCError>

pub fn flow_control_calculate_retransmission_length( resend_length: usize, term_buffer_length: usize, term_offset: usize, retransmit_receiver_window_multiple: usize, ) -> usize

pub fn agent_on_start_load(name: &CStr) -> aeron_agent_on_start_func_t

pub fn set_errno(errcode: c_int)

pub fn err_set( errcode: c_int, function: &CStr, filename: &CStr, line_number: c_int, format: &CStr, )

pub fn err_append( function: &CStr, filename: &CStr, line_number: c_int, format: &CStr, )

pub fn err_clear()

pub fn parse_port_range( range_str: &CStr, low_port: &mut u16, high_port: &mut u16, ) -> Result<i32, AeronCError>

pub fn config_parse_inferable_boolean( inferable_boolean: &CStr, def: aeron_inferable_boolean_t, ) -> aeron_inferable_boolean_t

pub fn parse_size64(str_: &CStr) -> Result<u64, AeronCError>

pub fn format_size64( value: u64, buffer: *mut c_char, buffer_size: usize, ) -> Result<i32, AeronCError>

pub fn parse_duration_ns(str_: &CStr) -> Result<u64, AeronCError>

pub fn format_duration_ns( duration_ns: u64, buffer: *mut c_char, buffer_size: usize, ) -> Result<i32, AeronCError>

pub fn parse_bool(str_: &CStr, def: bool) -> bool

pub fn address_split( address_str: &CStr, parsed_address: &AeronParsedAddress, ) -> Result<i32, AeronCError>

pub fn interface_split( interface_str: &CStr, parsed_interface: &AeronParsedInterface, ) -> Result<i32, AeronCError>

pub fn parse_get_line( line: *mut c_char, max_length: usize, buffer: &CStr, ) -> Result<i32, AeronCError>

pub fn config_prop_warning(name: &CStr, str_: &CStr)

pub fn config_parse_uint64( name: &CStr, str_: &CStr, def: u64, min: u64, max: u64, ) -> u64

pub fn config_parse_int32( name: &CStr, str_: &CStr, def: i32, min: i32, max: i32, ) -> i32

pub fn config_parse_int64( name: &CStr, str_: &CStr, def: i64, min: i64, max: i64, ) -> i64

pub fn config_parse_uint32( name: &CStr, str_: &CStr, def: u32, min: u32, max: u32, ) -> u32

pub fn config_parse_size64( name: &CStr, str_: &CStr, def: u64, min: u64, max: u64, ) -> u64

pub fn config_parse_duration_ns( name: &CStr, str_: &CStr, def: u64, min: u64, max: u64, ) -> u64

pub fn format_date(str_: *mut c_char, count: usize, timestamp: i64)

pub fn format_number_to_locale( value: c_longlong, buffer: *mut c_char, buffer_len: usize, ) -> *mut c_char

pub fn format_to_hex( str_: *mut c_char, str_length: usize, data: *const u8, data_len: usize, )

pub fn digit_count(value: u32) -> Result<i32, AeronCError>

pub fn ip_addr_resolver( host: &CStr, sockaddr: &SockaddrStorage, family_hint: c_int, protocol: c_int, ) -> Result<i32, AeronCError>

pub fn udp_port_resolver( port_str: &CStr, optional: bool, ) -> Result<i32, AeronCError>

pub fn try_parse_ipv4(host: &CStr, sockaddr: &SockaddrStorage) -> bool

pub fn ipv4_addr_resolver( host: &CStr, protocol: c_int, sockaddr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn try_parse_ipv6(host: &CStr, sockaddr: &SockaddrStorage) -> bool

pub fn ipv6_addr_resolver( host: &CStr, protocol: c_int, sockaddr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn lookup_interfaces<AeronIfaddrFuncHandlerImpl: AeronIfaddrFuncCallback>( func: Option<&Handler<AeronIfaddrFuncHandlerImpl>>, ) -> Result<i32, AeronCError>

pub fn lookup_interfaces_once<AeronIfaddrFuncHandlerImpl: FnMut(&str, Sockaddr, Sockaddr, c_uint) -> c_int>( func: AeronIfaddrFuncHandlerImpl, ) -> Result<i32, AeronCError>

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

pub fn lookup_interfaces_from_ifaddrs<AeronIfaddrFuncHandlerImpl: AeronIfaddrFuncCallback>( func: Option<&Handler<AeronIfaddrFuncHandlerImpl>>, ifaddrs: &Ifaddrs, ) -> Result<i32, AeronCError>

pub fn lookup_interfaces_from_ifaddrs_once<AeronIfaddrFuncHandlerImpl: FnMut(&str, Sockaddr, Sockaddr, c_uint) -> c_int>( func: AeronIfaddrFuncHandlerImpl, ifaddrs: &Ifaddrs, ) -> Result<i32, AeronCError>

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

pub fn set_getifaddrs( get_func: aeron_getifaddrs_func_t, free_func: aeron_freeifaddrs_func_t, )

pub fn interface_parse_and_resolve( interface_str: &CStr, sockaddr: &SockaddrStorage, ) -> Result<usize, AeronCError>

pub fn ipv4_netmask_from_prefixlen(prefixlen: usize) -> u32

pub fn find_interface( family: c_int, interface_str: &CStr, if_addr: &SockaddrStorage, if_index: *mut c_uint, ) -> Result<i32, AeronCError>

pub fn find_unicast_interface( family: c_int, interface_str: &CStr, interface_addr: &SockaddrStorage, interface_index: *mut c_uint, ) -> Result<i32, AeronCError>

pub fn format_source_identity( buffer: *mut c_char, length: usize, addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn netutil_get_so_buf_lengths( default_so_rcvbuf: &mut usize, default_so_sndbuf: &mut usize, ) -> Result<i32, AeronCError>

pub fn parse_named_interface( interface_str: &CStr, out: &AeronNamedInterface, ) -> Result<i32, AeronCError>

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

pub fn get_inner_mut(&self) -> &mut aeron_t

pub fn get_inner_ref(&self) -> &aeron_t

impl Aeron

pub fn new_blocking( context: &AeronContext, timeout: Duration, ) -> Result<Self, AeronCError>

Trait Implementations

impl Clone for Aeron

fn clone(&self) -> Aeron

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Aeron

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

Formats the value using the given formatter.

impl Deref for Aeron

type Target = aeron_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&Aeron> for *mut aeron_t

fn from(value: &Aeron) -> Self

Converts to this type from the input type.

impl From<*const aeron_stct> for Aeron

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

Converts to this type from the input type.

impl From<*mut aeron_stct> for Aeron

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

Converts to this type from the input type.

impl From<Aeron> for *mut aeron_t

fn from(value: Aeron) -> Self

Converts to this type from the input type.

impl From<Aeron> for aeron_t

fn from(value: Aeron) -> Self

Converts to this type from the input type.

impl From<aeron_stct> for Aeron

fn from(value: aeron_t) -> Self

Converts to this type from the input type.