Struct rusteron_media_driver::AeronPublicationImage

pub struct AeronPublicationImage { /* private fields */ }

Implementations

impl AeronPublicationImage

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

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

pub fn conductor_fields( &self, ) -> aeron_publication_image_stct_aeron_publication_image_conductor_fields_stct

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

pub fn connections( &self, ) -> aeron_publication_image_stct_image_connection_entries

pub fn source_address(&self) -> SockaddrStorage

pub fn source_identity_length(&self) -> usize

pub fn source_identity(&self) -> [c_char; 54]

pub fn loss_detector(&self) -> AeronLossDetector

pub fn feedback_delay_state(&self) -> AeronFeedbackDelayGeneratorState

pub fn mapped_raw_log(&self) -> AeronMappedRawLog

pub fn rcv_hwm_position(&self) -> AeronPosition

pub fn rcv_pos_position(&self) -> AeronPosition

pub fn log_meta_data(&self) -> AeronLogbufferMetadata

pub fn endpoint(&self) -> AeronReceiveChannelEndpoint

pub fn congestion_control(&self) -> AeronCongestionControlStrategy

pub fn nano_clock(&self) -> aeron_clock_func_t

pub fn epoch_clock(&self) -> aeron_clock_func_t

pub fn cached_clock(&self) -> AeronClockCache

pub fn loss_reporter(&self) -> AeronLossReporter

pub fn loss_reporter_offset(&self) -> aeron_loss_reporter_entry_offset_t

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

pub fn session_id(&self) -> i32

pub fn stream_id(&self) -> i32

pub fn initial_term_id(&self) -> i32

pub fn active_term_id(&self) -> i32

pub fn term_length(&self) -> i32

pub fn mtu_length(&self) -> i32

pub fn term_length_mask(&self) -> i32

pub fn log_file_name_length(&self) -> usize

pub fn position_bits_to_shift(&self) -> usize

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_publication_image_stct__bindgen_ty_1

pub fn last_loss_change_number(&self) -> i64

pub fn begin_loss_change(&self) -> i64

pub fn end_loss_change(&self) -> i64

pub fn loss_term_id(&self) -> i32

pub fn loss_term_offset(&self) -> i32

pub fn loss_length(&self) -> usize

pub fn begin_sm_change(&self) -> i64

pub fn end_sm_change(&self) -> i64

pub fn last_overrun_threshold(&self) -> i64

pub fn next_sm_position(&self) -> i64

pub fn next_sm_receiver_window_length(&self) -> i32

pub fn max_receiver_window_length(&self) -> i32

pub fn last_sm_change_number(&self) -> i64

pub fn last_sm_position(&self) -> i64

pub fn next_sm_deadline_ns(&self) -> i64

pub fn sm_timeout_ns(&self) -> i64

pub fn time_of_last_packet_ns(&self) -> i64

pub fn invalidation_reason(&self) -> &str

pub fn response_session_id(&self) -> i64

pub fn is_end_of_stream(&self) -> bool

pub fn is_sending_eos_sm(&self) -> bool

pub fn has_receiver_released(&self) -> bool

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

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

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

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

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

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

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

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 clean_buffer_to(&self, position: i64)

pub fn on_gap_detected( clientd: *mut c_void, term_id: i32, term_offset: i32, length: usize, )

pub fn track_rebuild(&self, now_ns: i64)

pub fn insert_packet( &self, destination: &AeronReceiveDestination, term_id: i32, term_offset: i32, buffer: &[u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn on_rttm( &self, header: &AeronRttmHeader, addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

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

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

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

pub fn add_destination( &self, destination: &AeronReceiveDestination, ) -> Result<i32, AeronCError>

pub fn remove_destination( &self, channel: &AeronUdpChannel, ) -> Result<i32, AeronCError>

pub fn add_connection_if_unknown( &self, destination: &AeronReceiveDestination, src_addr: &SockaddrStorage, )

pub fn receiver_release(&self)

pub fn invalidate(&self, reason_length: i32, reason: &str)

pub fn remove_response_session_id(&self)

pub fn stop_status_messages_if_not_active(&self)

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

Trait Implementations

impl Clone for AeronPublicationImage

fn clone(&self) -> AeronPublicationImage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronPublicationImage

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

Formats the value using the given formatter.

impl Deref for AeronPublicationImage

type Target = aeron_publication_image_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronPublicationImage> for *mut aeron_publication_image_t

fn from(value: &AeronPublicationImage) -> Self

Converts to this type from the input type.

impl From<*const aeron_publication_image_stct> for AeronPublicationImage

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

Converts to this type from the input type.

impl From<*mut aeron_publication_image_stct> for AeronPublicationImage

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

Converts to this type from the input type.

impl From<AeronPublicationImage> for *mut aeron_publication_image_t

fn from(value: AeronPublicationImage) -> Self

Converts to this type from the input type.

impl From<AeronPublicationImage> for aeron_publication_image_t

fn from(value: AeronPublicationImage) -> Self

Converts to this type from the input type.

impl From<aeron_publication_image_stct> for AeronPublicationImage

fn from(value: aeron_publication_image_t) -> Self

Converts to this type from the input type.