Struct rusteron_media_driver::AeronDriverSender

pub struct AeronDriverSender { /* private fields */ }

Implementations

impl AeronDriverSender

pub fn new( sender_proxy: AeronDriverSenderProxy, poller: aeron_udp_transport_poller_t, network_publications: aeron_driver_sender_stct_aeron_driver_sender_network_publications_stct, recv_buffers: aeron_driver_sender_stct_aeron_driver_sender_buffers_stct, data_paths: AeronUdpChannelDataPaths, total_bytes_sent_counter: &mut i64, errors_counter: &mut i64, invalid_frames_counter: &mut i64, status_messages_received_counter: &mut i64, nak_messages_received_counter: &mut i64, error_messages_received_counter: &mut i64, resolution_changes_counter: &mut i64, short_sends_counter: &mut i64, context: &AeronDriverContext, poller_poll_func: aeron_udp_transport_poller_poll_func_t, recvmmsg_func: aeron_udp_channel_transport_recvmmsg_func_t, error_log: &AeronDistinctErrorLog, status_message_read_timeout_ns: i64, control_poll_timeout_ns: i64, re_resolution_deadline_ns: i64, round_robin_index: usize, duty_cycle_counter: usize, duty_cycle_ratio: usize, padding: [u8; 64], ) -> Result<Self, AeronCError>

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

pub fn sender_proxy(&self) -> AeronDriverSenderProxy

pub fn poller(&self) -> aeron_udp_transport_poller_t

pub fn network_publications( &self, ) -> aeron_driver_sender_stct_aeron_driver_sender_network_publications_stct

pub fn recv_buffers( &self, ) -> aeron_driver_sender_stct_aeron_driver_sender_buffers_stct

pub fn data_paths(&self) -> AeronUdpChannelDataPaths

pub fn total_bytes_sent_counter(&self) -> &mut i64

pub fn errors_counter(&self) -> &mut i64

pub fn invalid_frames_counter(&self) -> &mut i64

pub fn status_messages_received_counter(&self) -> &mut i64

pub fn nak_messages_received_counter(&self) -> &mut i64

pub fn error_messages_received_counter(&self) -> &mut i64

pub fn resolution_changes_counter(&self) -> &mut i64

pub fn short_sends_counter(&self) -> &mut i64

pub fn context(&self) -> AeronDriverContext

pub fn poller_poll_func(&self) -> aeron_udp_transport_poller_poll_func_t

pub fn recvmmsg_func(&self) -> aeron_udp_channel_transport_recvmmsg_func_t

pub fn error_log(&self) -> AeronDistinctErrorLog

pub fn status_message_read_timeout_ns(&self) -> i64

pub fn control_poll_timeout_ns(&self) -> i64

pub fn re_resolution_deadline_ns(&self) -> i64

pub fn round_robin_index(&self) -> usize

pub fn duty_cycle_counter(&self) -> usize

pub fn duty_cycle_ratio(&self) -> usize

pub fn padding(&self) -> [u8; 64]

pub fn init( &self, context: &AeronDriverContext, system_counters: &AeronSystemCounters, error_log: &AeronDistinctErrorLog, ) -> Result<i32, AeronCError>

pub fn do_work(clientd: *mut c_void) -> Result<i32, AeronCError>

pub fn on_close(clientd: *mut c_void)

pub fn on_add_endpoint(clientd: *mut c_void, command: *mut c_void)

pub fn on_remove_endpoint(clientd: *mut c_void, command: *mut c_void)

pub fn on_add_publication(clientd: *mut c_void, command: *mut c_void)

pub fn on_remove_publication(clientd: *mut c_void, command: *mut c_void)

pub fn on_add_destination(clientd: *mut c_void, command: *mut c_void)

pub fn on_remove_destination(clientd: *mut c_void, command: *mut c_void)

pub fn on_remove_destination_by_id(clientd: *mut c_void, command: *mut c_void)

pub fn on_resolution_change(clientd: *mut c_void, command: *mut c_void)

pub fn do_send(&self, now_ns: i64) -> Result<i32, AeronCError>

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

Trait Implementations

impl Clone for AeronDriverSender

fn clone(&self) -> AeronDriverSender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronDriverSender

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

Formats the value using the given formatter.

impl Default for AeronDriverSender

This will create an instance where the struct is zeroed, use with care

fn default() -> Self

Returns the “default value” for a type.

impl Deref for AeronDriverSender

type Target = aeron_driver_sender_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronDriverSender> for *mut aeron_driver_sender_t

fn from(value: &AeronDriverSender) -> Self

Converts to this type from the input type.

impl From<*const aeron_driver_sender_stct> for AeronDriverSender

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

Converts to this type from the input type.

impl From<*mut aeron_driver_sender_stct> for AeronDriverSender

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

Converts to this type from the input type.

impl From<AeronDriverSender> for *mut aeron_driver_sender_t

fn from(value: AeronDriverSender) -> Self

Converts to this type from the input type.

impl From<AeronDriverSender> for aeron_driver_sender_t

fn from(value: AeronDriverSender) -> Self

Converts to this type from the input type.

impl From<aeron_driver_sender_stct> for AeronDriverSender

fn from(value: aeron_driver_sender_t) -> Self

Converts to this type from the input type.