Struct rusteron_media_driver::AeronDriverConductor

pub struct AeronDriverConductor { /* private fields */ }

Implementations

impl AeronDriverConductor

pub fn new( context: &AeronDriverContext, to_driver_commands: AeronMpscRb, to_clients: AeronBroadcastTransmitter, error_log: AeronDistinctErrorLog, counters_manager: AeronCountersManager, system_counters: AeronSystemCounters, conductor_proxy: AeronDriverConductorProxy, loss_reporter: AeronLossReporter, name_resolver: aeron_name_resolver_t, executor: aeron_executor_t, send_channel_endpoint_by_channel_map: AeronStrToPtrHashMap, receive_channel_endpoint_by_channel_map: AeronStrToPtrHashMap, 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: AeronDeque, 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], ) -> Result<Self, AeronCError>

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

pub fn context(&self) -> AeronDriverContext

pub fn to_driver_commands(&self) -> AeronMpscRb

pub fn to_clients(&self) -> AeronBroadcastTransmitter

pub fn error_log(&self) -> AeronDistinctErrorLog

pub fn counters_manager(&self) -> AeronCountersManager

pub fn system_counters(&self) -> AeronSystemCounters

pub fn conductor_proxy(&self) -> AeronDriverConductorProxy

pub fn loss_reporter(&self) -> AeronLossReporter

pub fn name_resolver(&self) -> aeron_name_resolver_t

pub fn executor(&self) -> aeron_executor_t

pub fn send_channel_endpoint_by_channel_map(&self) -> AeronStrToPtrHashMap

pub fn receive_channel_endpoint_by_channel_map(&self) -> AeronStrToPtrHashMap

pub fn clients(&self) -> aeron_driver_conductor_stct_client_stct

pub fn ipc_subscriptions( &self, ) -> aeron_driver_conductor_stct_ipc_subscriptions_stct

pub fn ipc_publications( &self, ) -> aeron_driver_conductor_stct_ipc_publication_stct

pub fn network_subscriptions( &self, ) -> aeron_driver_conductor_stct_network_subscriptions_stct

pub fn spy_subscriptions( &self, ) -> aeron_driver_conductor_stct_spy_subscriptions_stct

pub fn network_publications( &self, ) -> aeron_driver_conductor_stct_network_publication_stct

pub fn send_channel_endpoints( &self, ) -> aeron_driver_conductor_stct_send_channel_endpoint_stct

pub fn receive_channel_endpoints( &self, ) -> aeron_driver_conductor_stct_receive_channel_endpoint_stct

pub fn publication_images( &self, ) -> aeron_driver_conductor_stct_publication_image_stct

pub fn lingering_resources( &self, ) -> aeron_driver_conductor_stct_aeron_driver_conductor_lingering_resources_stct

pub fn end_of_life_queue(&self) -> AeronDeque

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

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

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

pub fn clock_update_deadline_ns(&self) -> i64

pub fn next_session_id(&self) -> i32

pub fn publication_reserved_session_id_low(&self) -> i32

pub fn publication_reserved_session_id_high(&self) -> i32

pub fn timeout_check_deadline_ns(&self) -> i64

pub fn time_of_last_to_driver_position_change_ns(&self) -> i64

pub fn last_command_consumer_position(&self) -> i64

pub fn async_client_command_in_flight(&self) -> bool

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

pub fn aeron_ipc_publication_on_time_event( &self, publication: &AeronIpcPublication, now_ns: i64, now_ms: i64, )

pub fn aeron_network_publication_on_time_event( &self, publication: &AeronNetworkPublication, now_ns: i64, now_ms: i64, )

pub fn aeron_publication_image_on_time_event( &self, image: &AeronPublicationImage, now_ns: i64, now_ms: i64, )

pub fn aeron_client_on_time_event( &self, client: &AeronClient, now_ns: i64, now_ms: i64, )

pub fn aeron_client_has_reached_end_of_life(&self, client: &AeronClient) -> bool

pub fn add_end_of_life_resource( &self, resource: *mut c_void, free_func: aeron_end_of_life_resource_free_t, )

pub fn aeron_client_delete(&self, arg1: &AeronClient)

pub fn aeron_ipc_publication_entry_on_time_event( &self, entry: &AeronIpcPublicationEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_ipc_publication_entry_has_reached_end_of_life( &self, entry: &AeronIpcPublicationEntry, ) -> bool

pub fn aeron_ipc_publication_entry_delete( &self, arg1: &AeronIpcPublicationEntry, )

pub fn aeron_ipc_publication_entry_free(&self, entry: &AeronIpcPublicationEntry)

pub fn aeron_network_publication_entry_on_time_event( &self, entry: &AeronNetworkPublicationEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_network_publication_entry_has_reached_end_of_life( &self, entry: &AeronNetworkPublicationEntry, ) -> bool

pub fn aeron_network_publication_entry_delete( &self, arg1: &AeronNetworkPublicationEntry, )

pub fn aeron_network_publication_entry_free( &self, entry: &AeronNetworkPublicationEntry, )

pub fn aeron_send_channel_endpoint_entry_on_time_event( &self, entry: &AeronSendChannelEndpointEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_send_channel_endpoint_entry_has_reached_end_of_life( &self, entry: &AeronSendChannelEndpointEntry, ) -> bool

pub fn aeron_send_channel_endpoint_entry_delete( &self, arg1: &AeronSendChannelEndpointEntry, )

pub fn aeron_receive_channel_endpoint_entry_on_time_event( &self, entry: &AeronReceiveChannelEndpointEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_receive_channel_endpoint_entry_has_reached_end_of_life( &self, entry: &AeronReceiveChannelEndpointEntry, ) -> bool

pub fn aeron_receive_channel_endpoint_entry_delete( &self, arg1: &AeronReceiveChannelEndpointEntry, )

pub fn aeron_publication_image_entry_on_time_event( &self, entry: &AeronPublicationImageEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_publication_image_entry_has_reached_end_of_life( &self, entry: &AeronPublicationImageEntry, ) -> bool

pub fn aeron_publication_image_entry_delete( &self, arg1: &AeronPublicationImageEntry, )

pub fn aeron_publication_image_entry_free( &self, entry: &AeronPublicationImageEntry, )

pub fn aeron_linger_resource_entry_on_time_event( &self, entry: &AeronLingerResourceEntry, now_ns: i64, now_ms: i64, )

pub fn aeron_linger_resource_entry_has_reached_end_of_life( &self, entry: &AeronLingerResourceEntry, ) -> bool

pub fn aeron_linger_resource_entry_delete( &self, arg1: &AeronLingerResourceEntry, )

pub fn image_transition_to_linger(&self, image: &AeronPublicationImage)

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

pub fn client_transmit( &self, msg_type_id: i32, message: *const c_void, length: usize, )

pub fn on_available_image( &self, correlation_id: i64, stream_id: i32, session_id: i32, log_file_name: &str, subscriber_position_id: i32, subscriber_registration_id: i64, source_identity: &str, )

pub fn on_unavailable_image( &self, correlation_id: i64, subscription_registration_id: i64, stream_id: i32, channel: &str, )

pub fn on_counter_ready(&self, registration_id: i64, counter_id: i32)

pub fn on_unavailable_counter(&self, registration_id: i64, counter_id: i32)

pub fn on_client_timeout(&self, correlation_id: i64)

pub fn on_static_counter(&self, correlation_id: i64, counter_id: i32)

pub fn cleanup_spies(&self, publication: &AeronNetworkPublication)

pub fn cleanup_network_publication(&self, publication: &AeronNetworkPublication)

pub fn on_command( msg_type_id: i32, message: *const c_void, length: usize, clientd: *mut c_void, ) -> aeron_rb_read_action_t

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

pub fn on_close(clientd: *mut c_void)

pub fn link_subscribable( &self, link: &AeronSubscriptionLink, subscribable: &AeronSubscribable, original_registration_id: i64, session_id: i32, stream_id: i32, join_position: i64, now_ns: i64, source_identity_length: usize, source_identity: &str, log_file_name_length: usize, log_file_name: &str, ) -> Result<i32, AeronCError>

pub fn unlink_all_subscribable(&self, link: &AeronSubscriptionLink)

pub fn on_add_ipc_publication( &self, command: &AeronPublicationCommand, is_exclusive: bool, ) -> Result<i32, AeronCError>

pub fn on_add_network_publication( &self, command: &AeronPublicationCommand, is_exclusive: bool, ) -> Result<i32, AeronCError>

pub fn on_remove_publication( &self, command: &AeronRemoveCommand, ) -> Result<i32, AeronCError>

pub fn on_add_ipc_subscription( &self, command: &AeronSubscriptionCommand, ) -> Result<i32, AeronCError>

pub fn on_add_spy_subscription( &self, command: &AeronSubscriptionCommand, ) -> Result<i32, AeronCError>

pub fn on_add_network_subscription( &self, command: &AeronSubscriptionCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_subscription( &self, command: &AeronRemoveCommand, ) -> Result<i32, AeronCError>

pub fn on_client_keepalive(&self, client_id: i64) -> Result<i32, AeronCError>

pub fn on_add_send_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_send_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_receive_send_destination_by_id( &self, command: &AeronDestinationByIdCommand, ) -> Result<i32, AeronCError>

pub fn on_add_receive_ipc_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_add_receive_spy_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_add_receive_network_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_receive_ipc_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_receive_spy_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_receive_network_destination( &self, command: &AeronDestinationCommand, ) -> Result<i32, AeronCError>

pub fn on_delete_receive_destination(clientd: *mut c_void, cmd: *mut c_void)

pub fn on_delete_send_destination(clientd: *mut c_void, cmd: *mut c_void)

pub fn on_add_counter( &self, command: &AeronCounterCommand, ) -> Result<i32, AeronCError>

pub fn on_remove_counter( &self, command: &AeronRemoveCommand, ) -> Result<i32, AeronCError>

pub fn on_add_static_counter( &self, command: &AeronStaticCounterCommand, ) -> Result<i32, AeronCError>

pub fn on_client_close( &self, command: &AeronCorrelatedCommand, ) -> Result<i32, AeronCError>

pub fn on_terminate_driver( &self, command: &AeronTerminateDriverCommand, ) -> Result<i32, AeronCError>

pub fn on_invalidate_image( &self, command: &AeronRejectImageCommand, ) -> Result<i32, AeronCError>

pub fn on_create_publication_image(clientd: *mut c_void, item: *mut c_void)

pub fn on_re_resolve_endpoint(clientd: *mut c_void, item: *mut c_void)

pub fn on_re_resolve_control(clientd: *mut c_void, item: *mut c_void)

pub fn on_receive_endpoint_removed(clientd: *mut c_void, item: *mut c_void)

pub fn on_response_setup(clientd: *mut c_void, item: *mut c_void)

pub fn on_response_connected(clientd: *mut c_void, item: *mut c_void)

pub fn on_publication_error(clientd: *mut c_void, item: *mut c_void)

pub fn on_release_resource(clientd: *mut c_void, item: *mut c_void)

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

Trait Implementations

impl Clone for AeronDriverConductor

fn clone(&self) -> AeronDriverConductor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronDriverConductor

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

Formats the value using the given formatter.

impl Default for AeronDriverConductor

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 AeronDriverConductor

type Target = aeron_driver_conductor_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronDriverConductor> for *mut aeron_driver_conductor_t

fn from(value: &AeronDriverConductor) -> Self

Converts to this type from the input type.

impl From<*const aeron_driver_conductor_stct> for AeronDriverConductor

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

Converts to this type from the input type.

impl From<*mut aeron_driver_conductor_stct> for AeronDriverConductor

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

Converts to this type from the input type.

impl From<AeronDriverConductor> for *mut aeron_driver_conductor_t

fn from(value: AeronDriverConductor) -> Self

Converts to this type from the input type.

impl From<AeronDriverConductor> for aeron_driver_conductor_t

fn from(value: AeronDriverConductor) -> Self

Converts to this type from the input type.

impl From<aeron_driver_conductor_stct> for AeronDriverConductor

fn from(value: aeron_driver_conductor_t) -> Self

Converts to this type from the input type.