Struct aeron_publication_image_stct

#[repr(C)]
pub struct aeron_publication_image_stct {

    pub padding_before: [u8; 64],
    pub conductor_fields: aeron_publication_image_stct_aeron_publication_image_conductor_fields_stct,
    pub padding_after: [u8; 64],
    pub connections: aeron_publication_image_stct_image_connection_entries,
    pub source_address: sockaddr_storage,
    pub source_identity_length: usize,
    pub source_identity: [c_char; 54],
    pub loss_detector: aeron_loss_detector_t,
    pub feedback_delay_state: aeron_feedback_delay_generator_state_t,
    pub mapped_raw_log: aeron_mapped_raw_log_t,
    pub rcv_hwm_position: aeron_position_t,
    pub rcv_pos_position: aeron_position_t,
    pub rcv_naks_sent: aeron_atomic_counter_t,
    pub log_meta_data: *mut aeron_logbuffer_metadata_t,
    pub endpoint: *mut aeron_receive_channel_endpoint_t,
    pub congestion_control: *mut aeron_congestion_control_strategy_t,
    pub nano_clock: aeron_clock_func_t,
    pub epoch_clock: aeron_clock_func_t,
    pub cached_clock: *mut aeron_clock_cache_t,
    pub log_file_name: *mut c_char,
    pub session_id: i32,
    pub stream_id: i32,
    pub initial_term_id: i32,
    pub active_term_id: i32,
    pub term_length: i32,
    pub mtu_length: i32,
    pub term_length_mask: i32,
    pub log_file_name_length: usize,
    pub position_bits_to_shift: usize,
    pub raw_log_close_func: aeron_raw_log_close_func_t,
    pub raw_log_free_func: aeron_raw_log_free_func_t,
    pub log: aeron_publication_image_stct__bindgen_ty_1,
    pub last_loss_change_number: i64,
    pub begin_loss_change: i64,
    pub end_loss_change: i64,
    pub loss_term_id: i32,
    pub loss_term_offset: i32,
    pub loss_length: usize,
    pub begin_sm_change: i64,
    pub end_sm_change: i64,
    pub last_overrun_threshold: i64,
    pub next_sm_position: i64,
    pub next_sm_receiver_window_length: i32,
    pub max_receiver_window_length: i32,
    pub last_sm_change_number: i64,
    pub last_sm_position: i64,
    pub next_sm_deadline_ns: i64,
    pub sm_timeout_ns: i64,
    pub time_of_last_packet_ns: i64,
    pub invalidation_reason: *const c_char,
    pub is_sm_enabled: bool,
    pub response_session_id: i64,
    pub is_end_of_stream: bool,
    pub is_sending_eos_sm: bool,
    pub has_receiver_released: bool,
    pub heartbeats_received_counter: *mut i64,
    pub flow_control_under_runs_counter: *mut i64,
    pub flow_control_over_runs_counter: *mut i64,
    pub status_messages_sent_counter: *mut i64,
    pub nak_messages_sent_counter: *mut i64,
    pub loss_gap_fills_counter: *mut i64,
    pub mapped_bytes_counter: *mut i64,
    pub publication_images_revoked_counter: *mut i64,
}

Fields

padding_before: [u8; 64]

conductor_fields: aeron_publication_image_stct_aeron_publication_image_conductor_fields_stct

padding_after: [u8; 64]

connections: aeron_publication_image_stct_image_connection_entries

source_address: sockaddr_storage

source_identity_length: usize

source_identity: [c_char; 54]

loss_detector: aeron_loss_detector_t

feedback_delay_state: aeron_feedback_delay_generator_state_t

mapped_raw_log: aeron_mapped_raw_log_t

rcv_hwm_position: aeron_position_t

rcv_pos_position: aeron_position_t

rcv_naks_sent: aeron_atomic_counter_t

log_meta_data: *mut aeron_logbuffer_metadata_t

endpoint: *mut aeron_receive_channel_endpoint_t

congestion_control: *mut aeron_congestion_control_strategy_t

nano_clock: aeron_clock_func_t

epoch_clock: aeron_clock_func_t

cached_clock: *mut aeron_clock_cache_t

log_file_name: *mut c_char

session_id: i32

stream_id: i32

initial_term_id: i32

active_term_id: i32

term_length: i32

mtu_length: i32

term_length_mask: i32

log_file_name_length: usize

position_bits_to_shift: usize

raw_log_close_func: aeron_raw_log_close_func_t

raw_log_free_func: aeron_raw_log_free_func_t

log: aeron_publication_image_stct__bindgen_ty_1

last_loss_change_number: i64

begin_loss_change: i64

end_loss_change: i64

loss_term_id: i32

loss_term_offset: i32

loss_length: usize

begin_sm_change: i64

end_sm_change: i64

last_overrun_threshold: i64

next_sm_position: i64

next_sm_receiver_window_length: i32

max_receiver_window_length: i32

last_sm_change_number: i64

last_sm_position: i64

next_sm_deadline_ns: i64

sm_timeout_ns: i64

time_of_last_packet_ns: i64

invalidation_reason: *const c_char

is_sm_enabled: bool

response_session_id: i64

is_end_of_stream: bool

is_sending_eos_sm: bool

has_receiver_released: bool

heartbeats_received_counter: *mut i64

flow_control_under_runs_counter: *mut i64

flow_control_over_runs_counter: *mut i64

status_messages_sent_counter: *mut i64

nak_messages_sent_counter: *mut i64

loss_gap_fills_counter: *mut i64

mapped_bytes_counter: *mut i64

publication_images_revoked_counter: *mut i64

Trait Implementations

impl Clone for aeron_publication_image_stct

fn clone(&self) -> aeron_publication_image_stct

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for aeron_publication_image_stct

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

Formats the value using the given formatter.

impl Default for aeron_publication_image_stct

fn default() -> Self

Returns the “default value” for a 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.

impl PartialEq for aeron_publication_image_stct

fn eq(&self, other: &aeron_publication_image_stct) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for aeron_publication_image_stct

impl StructuralPartialEq for aeron_publication_image_stct