#[repr(C)]pub struct aeron_driver_conductor_stct {Show 35 fields
pub context: *mut aeron_driver_context_t,
pub to_driver_commands: aeron_mpsc_rb_t,
pub to_clients: aeron_broadcast_transmitter_t,
pub error_log: aeron_distinct_error_log_t,
pub counters_manager: aeron_counters_manager_t,
pub system_counters: aeron_system_counters_t,
pub conductor_proxy: aeron_driver_conductor_proxy_t,
pub loss_reporter: aeron_loss_reporter_t,
pub name_resolver: aeron_name_resolver_t,
pub executor: aeron_executor_t,
pub send_channel_endpoint_by_channel_map: aeron_str_to_ptr_hash_map_t,
pub receive_channel_endpoint_by_channel_map: aeron_str_to_ptr_hash_map_t,
pub clients: aeron_driver_conductor_stct_client_stct,
pub ipc_subscriptions: aeron_driver_conductor_stct_ipc_subscriptions_stct,
pub ipc_publications: aeron_driver_conductor_stct_ipc_publication_stct,
pub network_subscriptions: aeron_driver_conductor_stct_network_subscriptions_stct,
pub spy_subscriptions: aeron_driver_conductor_stct_spy_subscriptions_stct,
pub network_publications: aeron_driver_conductor_stct_network_publication_stct,
pub send_channel_endpoints: aeron_driver_conductor_stct_send_channel_endpoint_stct,
pub receive_channel_endpoints: aeron_driver_conductor_stct_receive_channel_endpoint_stct,
pub publication_images: aeron_driver_conductor_stct_publication_image_stct,
pub lingering_resources: aeron_driver_conductor_stct_aeron_driver_conductor_lingering_resources_stct,
pub end_of_life_queue: aeron_deque_t,
pub errors_counter: *mut i64,
pub unblocked_commands_counter: *mut i64,
pub client_timeouts_counter: *mut i64,
pub clock_update_deadline_ns: i64,
pub next_session_id: i32,
pub publication_reserved_session_id_low: i32,
pub publication_reserved_session_id_high: i32,
pub timeout_check_deadline_ns: i64,
pub time_of_last_to_driver_position_change_ns: i64,
pub last_command_consumer_position: i64,
pub async_client_command_in_flight: bool,
pub padding: [u8; 64],
}
Fields§
§context: *mut aeron_driver_context_t
§to_driver_commands: aeron_mpsc_rb_t
§to_clients: aeron_broadcast_transmitter_t
§error_log: aeron_distinct_error_log_t
§counters_manager: aeron_counters_manager_t
§system_counters: aeron_system_counters_t
§conductor_proxy: aeron_driver_conductor_proxy_t
§loss_reporter: aeron_loss_reporter_t
§name_resolver: aeron_name_resolver_t
§executor: aeron_executor_t
§send_channel_endpoint_by_channel_map: aeron_str_to_ptr_hash_map_t
§receive_channel_endpoint_by_channel_map: aeron_str_to_ptr_hash_map_t
§clients: aeron_driver_conductor_stct_client_stct
§ipc_subscriptions: aeron_driver_conductor_stct_ipc_subscriptions_stct
§ipc_publications: aeron_driver_conductor_stct_ipc_publication_stct
§network_subscriptions: aeron_driver_conductor_stct_network_subscriptions_stct
§spy_subscriptions: aeron_driver_conductor_stct_spy_subscriptions_stct
§network_publications: aeron_driver_conductor_stct_network_publication_stct
§send_channel_endpoints: aeron_driver_conductor_stct_send_channel_endpoint_stct
§receive_channel_endpoints: aeron_driver_conductor_stct_receive_channel_endpoint_stct
§publication_images: aeron_driver_conductor_stct_publication_image_stct
§lingering_resources: aeron_driver_conductor_stct_aeron_driver_conductor_lingering_resources_stct
§end_of_life_queue: aeron_deque_t
§errors_counter: *mut i64
§unblocked_commands_counter: *mut i64
§client_timeouts_counter: *mut i64
§clock_update_deadline_ns: i64
§next_session_id: i32
§publication_reserved_session_id_low: i32
§publication_reserved_session_id_high: i32
§timeout_check_deadline_ns: i64
§time_of_last_to_driver_position_change_ns: i64
§last_command_consumer_position: i64
§async_client_command_in_flight: bool
§padding: [u8; 64]
Trait Implementations§
source§impl Clone for aeron_driver_conductor_stct
impl Clone for aeron_driver_conductor_stct
source§fn clone(&self) -> aeron_driver_conductor_stct
fn clone(&self) -> aeron_driver_conductor_stct
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl From<aeron_driver_conductor_stct> for AeronDriverConductor
impl From<aeron_driver_conductor_stct> for AeronDriverConductor
source§fn from(value: aeron_driver_conductor_t) -> Self
fn from(value: aeron_driver_conductor_t) -> Self
Converts to this type from the input type.
impl Copy for aeron_driver_conductor_stct
Auto Trait Implementations§
impl Freeze for aeron_driver_conductor_stct
impl RefUnwindSafe for aeron_driver_conductor_stct
impl !Send for aeron_driver_conductor_stct
impl !Sync for aeron_driver_conductor_stct
impl Unpin for aeron_driver_conductor_stct
impl UnwindSafe for aeron_driver_conductor_stct
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)