Struct rusteron_media_driver::AeronNetworkPublication

pub struct AeronNetworkPublication { /* private fields */ }

Implementations

impl AeronNetworkPublication

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

pub fn conductor_fields( &self, ) -> aeron_network_publication_stct_aeron_network_publication_conductor_fields_stct

pub fn conductor_fields_pad(&self) -> [u8; 112]

pub fn mapped_raw_log(&self) -> AeronMappedRawLog

pub fn pub_pos_position(&self) -> AeronPosition

pub fn pub_lmt_position(&self) -> AeronPosition

pub fn snd_pos_position(&self) -> AeronPosition

pub fn snd_lmt_position(&self) -> AeronPosition

pub fn snd_bpe_counter(&self) -> AeronAtomicCounter

pub fn retransmit_handler(&self) -> AeronRetransmitHandler

pub fn log_meta_data(&self) -> AeronLogbufferMetadata

pub fn endpoint(&self) -> AeronSendChannelEndpoint

pub fn flow_control(&self) -> AeronFlowControlStrategy

pub fn cached_clock(&self) -> AeronClockCache

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

pub fn has_initial_connection(&self) -> bool

pub fn track_sender_limits(&self) -> bool

pub fn time_of_last_data_or_heartbeat_ns(&self) -> i64

pub fn current_messages_per_send(&self) -> usize

pub fn status_message_deadline_ns(&self) -> i64

pub fn time_of_last_setup_ns(&self) -> i64

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

pub fn endpoint_address(&self) -> SockaddrStorage

pub fn log_file_name(&self) -> *mut c_char

pub fn term_buffer_length(&self) -> i64

pub fn term_window_length(&self) -> i64

pub fn trip_gain(&self) -> i64

pub fn linger_timeout_ns(&self) -> i64

pub fn unblock_timeout_ns(&self) -> i64

pub fn connection_timeout_ns(&self) -> i64

pub fn untethered_window_limit_timeout_ns(&self) -> i64

pub fn untethered_resting_timeout_ns(&self) -> i64

pub fn tag(&self) -> i64

pub fn response_correlation_id(&self) -> i64

pub fn session_id(&self) -> i32

pub fn stream_id(&self) -> i32

pub fn initial_term_id(&self) -> i32

pub fn starting_term_id(&self) -> i32

pub fn term_length_mask(&self) -> i32

pub fn starting_term_offset(&self) -> usize

pub fn log_file_name_length(&self) -> usize

pub fn position_bits_to_shift(&self) -> usize

pub fn mtu_length(&self) -> usize

pub fn max_messages_per_send(&self) -> usize

pub fn spies_simulate_connection(&self) -> bool

pub fn signal_eos(&self) -> bool

pub fn is_setup_elicited(&self) -> bool

pub fn is_exclusive(&self) -> bool

pub fn is_response(&self) -> bool

pub fn has_receivers(&self) -> bool

pub fn has_spies(&self) -> bool

pub fn is_connected(&self) -> bool

pub fn is_end_of_stream(&self) -> bool

pub fn has_sender_released(&self) -> bool

pub fn has_received_unicast_eos(&self) -> bool

pub fn raw_log_close_func(&self) -> aeron_raw_log_close_func_t

pub fn raw_log_free_func(&self) -> aeron_raw_log_free_func_t

pub fn log(&self) -> aeron_network_publication_stct__bindgen_ty_1

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

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

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

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

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

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

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

pub fn receiver_liveness_tracker(&self) -> AeronInt64CounterMap

pub fn location( dst: *mut c_char, length: usize, aeron_dir: &str, correlation_id: i64, ) -> Result<i32, AeronCError>

pub fn free(&self) -> bool

pub fn incref(clientd: *mut c_void)

pub fn decref(clientd: *mut c_void)

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

pub fn resend( clientd: *mut c_void, term_id: i32, term_offset: i32, length: usize, ) -> Result<i32, AeronCError>

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

pub fn on_nak( &self, term_id: i32, term_offset: i32, length: i32, ) -> Result<i32, AeronCError>

pub fn on_status_message( &self, conductor_proxy: &AeronDriverConductorProxy, buffer: &[u8], addr: &SockaddrStorage, )

pub fn on_error( &self, destination_registration_id: i64, buffer: &[u8], src_address: &SockaddrStorage, pStct: &AeronDriverConductorProxy, )

pub fn on_rttm(&self, buffer: &[u8], addr: &SockaddrStorage)

pub fn clean_buffer(&self, position: i64)

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

pub fn check_for_blocked_publisher( &self, now_ns: i64, producer_position: i64, snd_pos: i64, )

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

Trait Implementations

impl Clone for AeronNetworkPublication

fn clone(&self) -> AeronNetworkPublication

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronNetworkPublication

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

Formats the value using the given formatter.

impl Deref for AeronNetworkPublication

type Target = aeron_network_publication_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronNetworkPublication> for *mut aeron_network_publication_t

fn from(value: &AeronNetworkPublication) -> Self

Converts to this type from the input type.

impl From<*const aeron_network_publication_stct> for AeronNetworkPublication

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

Converts to this type from the input type.

impl From<*mut aeron_network_publication_stct> for AeronNetworkPublication

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

Converts to this type from the input type.

impl From<AeronNetworkPublication> for *mut aeron_network_publication_t

fn from(value: AeronNetworkPublication) -> Self

Converts to this type from the input type.

impl From<AeronNetworkPublication> for aeron_network_publication_t

fn from(value: AeronNetworkPublication) -> Self

Converts to this type from the input type.

impl From<aeron_network_publication_stct> for AeronNetworkPublication

fn from(value: aeron_network_publication_t) -> Self

Converts to this type from the input type.