[][src]Crate libaeron_driver_sys

Re-exports

pub use self::aeron_controlled_fragment_handler_action_en as aeron_controlled_fragment_handler_action_t;
pub use self::aeron_subscription_tether_state_enum::Type as aeron_subscription_tether_state_t;
pub use self::aeron_threading_mode_enum::Type as aeron_threading_mode_t;
pub use self::aeron_inferable_boolean_enum::Type as aeron_inferable_boolean_t;
pub use self::aeron_uri_type_enum::Type as aeron_uri_type_t;
pub use self::aeron_udp_channel_transport_affinity_en as aeron_udp_channel_transport_affinity_t;
pub use self::aeron_queue_offer_result_stct as aeron_queue_offer_result_t;
pub use self::aeron_rb_write_result_stct as aeron_rb_write_result_t;
pub use self::aeron_system_counter_enum_stct as aeron_system_counter_enum_t;
pub use self::aeron_ipc_publication_state_enum::Type as aeron_ipc_publication_state_t;
pub use self::aeron_retransmit_action_state_enum::Type as aeron_retransmit_action_state_t;
pub use self::aeron_network_publication_state_enum::Type as aeron_network_publication_state_t;
pub use self::aeron_send_channel_endpoint_status_enum::Type as aeron_send_channel_endpoint_status_t;
pub use self::aeron_receive_channel_endpoint_status_enum::Type as aeron_receive_channel_endpoint_status_t;
pub use self::aeron_publication_image_state_enum::Type as aeron_publication_image_state_t;

Modules

aeron_inferable_boolean_enum
aeron_ipc_publication_state_enum
aeron_network_publication_state_enum
aeron_publication_image_state_enum
aeron_receive_channel_endpoint_status_enum
aeron_retransmit_action_state_enum
aeron_send_channel_endpoint_status_enum
aeron_subscription_tether_state_enum
aeron_threading_mode_enum
aeron_uri_type_enum

Structs

__pthread_internal_list
__pthread_mutex_s
addrinfo
aeron_agent_runner_stct
aeron_broadcast_descriptor_stct
aeron_broadcast_record_descriptor_stct
aeron_broadcast_transmitter_stct
aeron_buffer_claim_stct

Structure used to hold information for a try_claim function call.

aeron_channel_endpoint_status_key_layout_stct
aeron_client_registering_resource_stct
aeron_client_stct
aeron_client_stct_counter_link_stct
aeron_client_stct_publication_link_stct
aeron_client_timeout_stct
aeron_clock_cache_stct
aeron_cnc_metadata_stct
aeron_command_add_rcv_destination_stct
aeron_command_base_stct
aeron_command_create_publication_image_stct
aeron_command_delete_destination_stct
aeron_command_destination_stct
aeron_command_publication_image_stct
aeron_command_re_resolve_stct
aeron_command_receiver_resolution_change_stct
aeron_command_remove_cool_down_stct
aeron_command_remove_rcv_destination_stct
aeron_command_sender_resolution_change_stct
aeron_command_subscription_stct
aeron_congestion_control_strategy_stct
aeron_context_stct
aeron_controlled_fragment_assembler_stct
aeron_correlated_command_stct
aeron_counter_command_stct
aeron_counter_link_stct
aeron_counter_metadata_descriptor_stct
aeron_counter_stct
aeron_counter_update_stct
aeron_counter_value_descriptor_stct
aeron_counters_manager_stct
aeron_counters_reader_stct
aeron_data_header_stct
aeron_data_packet_dispatcher_stct
aeron_data_packet_dispatcher_stct_aeron_data_packet_dispatcher_tokens_stct
aeron_data_packet_dispatcher_stream_interest_stct
aeron_destination_command_stct
aeron_distinct_error_log_observation_list_stct
aeron_distinct_error_log_stct
aeron_distinct_observation_stct
aeron_driver_conductor_proxy_stct
aeron_driver_conductor_stct
aeron_driver_conductor_stct_aeron_driver_conductor_lingering_resources_stct
aeron_driver_conductor_stct_client_stct
aeron_driver_conductor_stct_ipc_publication_stct
aeron_driver_conductor_stct_ipc_subscriptions_stct
aeron_driver_conductor_stct_network_publication_stct
aeron_driver_conductor_stct_network_subscriptions_stct
aeron_driver_conductor_stct_publication_image_stct
aeron_driver_conductor_stct_receive_channel_endpoint_stct
aeron_driver_conductor_stct_send_channel_endpoint_stct
aeron_driver_conductor_stct_spy_subscriptions_stct
aeron_driver_context_stct
aeron_driver_context_stct__bindgen_ty_1
aeron_driver_context_stct__bindgen_ty_2
aeron_driver_managed_resource_stct
aeron_driver_receiver_image_entry_stct
aeron_driver_receiver_pending_setup_entry_stct
aeron_driver_receiver_proxy_stct
aeron_driver_receiver_stct
aeron_driver_receiver_stct_aeron_driver_receiver_buffers_stct
aeron_driver_receiver_stct_aeron_driver_receiver_images_stct
aeron_driver_receiver_stct_aeron_driver_receiver_pending_setups_stct
aeron_driver_sender_network_publication_entry_stct
aeron_driver_sender_proxy_stct
aeron_driver_sender_stct
aeron_driver_sender_stct_aeron_driver_sender_buffers_stct
aeron_driver_sender_stct_aeron_driver_sender_network_publications_stct
aeron_driver_stct
aeron_error_log_entry_stct
aeron_error_response_stct
aeron_exclusive_publication_stct
aeron_feedback_delay_generator_state_stct
aeron_feedback_delay_generator_state_stct_optimal_delay_stct
aeron_feedback_delay_generator_state_stct_static_delay_stct
aeron_flow_control_strategy_stct
aeron_flow_control_strategy_supplier_func_table_entry_stct
aeron_flow_control_tagged_options_stct
aeron_flow_control_tagged_options_stct__bindgen_ty_1
aeron_flow_control_tagged_options_stct__bindgen_ty_2
aeron_flow_control_tagged_options_stct__bindgen_ty_3
aeron_fragment_assembler_stct
aeron_frame_header_stct
aeron_header_stct
aeron_heartbeat_timestamp_key_layout_stct
aeron_idle_strategy_stct
aeron_image_buffers_ready_stct
aeron_image_controlled_fragment_assembler_stct
aeron_image_fragment_assembler_stct
aeron_image_message_stct
aeron_image_stct
aeron_int64_to_ptr_hash_map_stct
aeron_int64_counter_map_stct
aeron_int64_to_tagged_ptr_entry_stct
aeron_int64_to_tagged_ptr_hash_map_stct
aeron_iovec_stct

Structure to hold pointer to a buffer and the buffer length.

aeron_ipc_channel_params_stct
aeron_ipc_publication_entry_stct
aeron_ipc_publication_stct
aeron_ipc_publication_stct_aeron_ipc_publication_conductor_fields_stct
aeron_linger_resource_entry_stct
aeron_local_sockaddr_key_layout_stct
aeron_log_buffer_stct
aeron_logbuffer_metadata_stct
aeron_loss_detector_gap_stct
aeron_loss_detector_stct
aeron_loss_reporter_entry_stct
aeron_loss_reporter_stct
aeron_mapped_buffer_stct
aeron_mapped_file_stct
aeron_mapped_raw_log_stct
aeron_mpsc_concurrent_array_queue_stct
aeron_mpsc_concurrent_array_queue_stct__bindgen_ty_1
aeron_mpsc_concurrent_array_queue_stct__bindgen_ty_2
aeron_mpsc_rb_stct
aeron_nak_header_stct
aeron_name_resolver_stct
aeron_network_publication_entry_stct
aeron_network_publication_stct
aeron_network_publication_stct_aeron_network_publication_conductor_fields_stct
aeron_operation_succeeded_stct
aeron_per_thread_error_stct
aeron_position_stct
aeron_publication_buffers_ready_stct
aeron_publication_command_stct
aeron_publication_image_connection_stct
aeron_publication_image_entry_stct
aeron_publication_image_stct
aeron_publication_image_stct_aeron_publication_image_conductor_fields_stct
aeron_publication_image_stct_image_connection_entries
aeron_publication_link_stct
aeron_publication_stct
aeron_rb_descriptor_stct
aeron_rb_record_descriptor_stct
aeron_receive_channel_endpoint_entry_stct
aeron_receive_channel_endpoint_stct
aeron_receive_channel_endpoint_stct__bindgen_ty_1
aeron_receive_channel_endpoint_stct_aeron_receive_channel_endpoint_conductor_fields_stct
aeron_receive_channel_endpoint_stct_destination_stct
aeron_receive_destination_entry_stct
aeron_receive_destination_stct
aeron_receive_destination_stct_aeron_receive_destination_conductor_fields_stct
aeron_remove_command_stct
aeron_resolution_header_ipv4_stct
aeron_resolution_header_ipv6_stct
aeron_resolution_header_stct
aeron_retransmit_action_stct
aeron_retransmit_handler_stct
aeron_rttm_header_stct
aeron_send_channel_endpoint_entry_stct
aeron_send_channel_endpoint_stct
aeron_send_channel_endpoint_stct_aeron_send_channel_endpoint_conductor_fields_stct
aeron_setup_header_stct
aeron_spsc_concurrent_array_queue_stct
aeron_spsc_concurrent_array_queue_stct__bindgen_ty_1
aeron_spsc_concurrent_array_queue_stct__bindgen_ty_2
aeron_status_message_header_stct
aeron_status_message_optional_header_stct
aeron_stct
aeron_str_to_ptr_hash_map_key_stct
aeron_str_to_ptr_hash_map_stct
aeron_stream_position_counter_key_layout_stct
aeron_subscribable_list_entry_stct
aeron_subscribable_stct
aeron_subscription_command_stct
aeron_subscription_link_stct
aeron_subscription_link_stct_subscribable_list_stct
aeron_subscription_ready_stct
aeron_subscription_stct
aeron_system_counter_stct
aeron_system_counters_stct
aeron_terminate_driver_command_stct
aeron_tetherable_position_stct
aeron_udp_channel_data_paths_stct
aeron_udp_channel_incoming_interceptor_stct
aeron_udp_channel_interceptor_bindings_stct
aeron_udp_channel_interceptor_bindings_stct_interceptor_meta_info_fields
aeron_udp_channel_outgoing_interceptor_stct
aeron_udp_channel_params_stct
aeron_udp_channel_stct
aeron_udp_channel_transport_bindings_stct
aeron_udp_channel_transport_bindings_stct_meta_info_fields
aeron_udp_channel_transport_entry_stct
aeron_udp_channel_transport_stct
aeron_udp_destination_entry_stct
aeron_udp_destination_tracker_stct
aeron_udp_destination_tracker_stct_aeron_udp_destination_tracker_destinations_stct
aeron_udp_transport_poller_stct
aeron_udp_transport_poller_stct_aeron_udp_channel_transports_stct
aeron_uri_param_stct
aeron_uri_params_stct
aeron_uri_publication_params_stct
aeron_uri_stct
aeron_uri_subscription_params_stct
ifaddrs
in6_addr
in_addr
iovec
mmsghdr
msghdr
sockaddr
sockaddr_storage

Constants

AERON_AGENT_ON_START_FUNCTION_ENV_VAR
AERON_AGENT_RUNNER_CONDUCTOR
AERON_AGENT_RUNNER_MAX
AERON_AGENT_RUNNER_RECEIVER
AERON_AGENT_RUNNER_SENDER
AERON_AGENT_RUNNER_SHARED
AERON_AGENT_RUNNER_SHARED_NETWORK
AERON_AGENT_STATE_INITED
AERON_AGENT_STATE_MANUAL
AERON_AGENT_STATE_STARTED
AERON_AGENT_STATE_STOPPED
AERON_AGENT_STATE_STOPPING
AERON_AGENT_STATE_UNUSED
AERON_BROADCAST_PADDING_MSG_TYPE_ID
AERON_CACHE_LINE_LENGTH
AERON_CHANNEL_STATUS_INDICATOR_NOT_ALLOCATED
AERON_CLIENT_LIVENESS_TIMEOUT_ENV_VAR
AERON_CLIENT_RESOURCE_LINGER_DURATION_ENV_VAR
AERON_CNC_FILE
AERON_COMMAND_ADD_COUNTER
AERON_COMMAND_ADD_DESTINATION
AERON_COMMAND_ADD_EXCLUSIVE_PUBLICATION
AERON_COMMAND_ADD_PUBLICATION
AERON_COMMAND_ADD_RCV_DESTINATION
AERON_COMMAND_ADD_SUBSCRIPTION
AERON_COMMAND_CLIENT_CLOSE
AERON_COMMAND_CLIENT_KEEPALIVE
AERON_COMMAND_QUEUE_CAPACITY
AERON_COMMAND_REMOVE_COUNTER
AERON_COMMAND_REMOVE_DESTINATION
AERON_COMMAND_REMOVE_PUBLICATION
AERON_COMMAND_REMOVE_RCV_DESTINATION
AERON_COMMAND_REMOVE_SUBSCRIPTION
AERON_COMMAND_TERMINATE_DRIVER
AERON_COMPILER_GCC
AERON_COMPILER_LLVM
AERON_CONDUCTOR_IDLE_STRATEGY_ENV_VAR
AERON_CONDUCTOR_IDLE_STRATEGY_INIT_ARGS_ENV_VAR
AERON_CONGESTIONCONTROL_SUPPLIER_ENV_VAR
AERON_COUNTERS_FREE_TO_REUSE_TIMEOUT_ENV_VAR
AERON_COUNTERS_VALUES_BUFFER_LENGTH_ENV_VAR
AERON_COUNTER_CHANNEL_ENDPOINT_STATUS_ERRORED
AERON_COUNTER_CHANNEL_ENDPOINT_STATUS_INITIALIZING
AERON_COUNTER_CHANNEL_ENDPOINT_STATUS_NO_ID_ALLOCATED
AERON_COUNTER_CLIENT_HEARTBEAT_TIMESTAMP_NAME
AERON_COUNTER_CLIENT_HEARTBEAT_TIMESTAMP_TYPE_ID
AERON_COUNTER_LOCAL_SOCKADDR_TYPE_ID
AERON_COUNTER_PUBLISHER_LIMIT_NAME
AERON_COUNTER_PUBLISHER_LIMIT_TYPE_ID
AERON_COUNTER_PUBLISHER_POSITION_NAME
AERON_COUNTER_PUBLISHER_POSITION_TYPE_ID
AERON_COUNTER_RCV_LOCAL_SOCKADDR_NAME
AERON_COUNTER_RECEIVER_HWM_NAME
AERON_COUNTER_RECEIVER_HWM_TYPE_ID
AERON_COUNTER_RECEIVER_POSITION_NAME
AERON_COUNTER_RECEIVER_POSITION_TYPE_ID
AERON_COUNTER_RECEIVE_CHANNEL_STATUS_NAME
AERON_COUNTER_RECEIVE_CHANNEL_STATUS_TYPE_ID
AERON_COUNTER_RECORD_ALLOCATED
AERON_COUNTER_RECORD_RECLAIMED
AERON_COUNTER_RECORD_UNUSED
AERON_COUNTER_SENDER_BPE_NAME
AERON_COUNTER_SENDER_BPE_TYPE_ID
AERON_COUNTER_SENDER_LIMIT_NAME
AERON_COUNTER_SENDER_LIMIT_TYPE_ID
AERON_COUNTER_SENDER_POSITION_NAME
AERON_COUNTER_SENDER_POSITION_TYPE_ID
AERON_COUNTER_SEND_CHANNEL_STATUS_NAME
AERON_COUNTER_SEND_CHANNEL_STATUS_TYPE_ID
AERON_COUNTER_SND_LOCAL_SOCKADDR_NAME
AERON_COUNTER_SUBSCRIPTION_POSITION_NAME
AERON_COUNTER_SUBSCRIPTION_POSITION_TYPE_ID
AERON_CPU_X64
AERON_DATA_HEADER_DEFAULT_RESERVED_VALUE
AERON_DIR_DELETE_ON_SHUTDOWN_ENV_VAR
AERON_DIR_DELETE_ON_START_ENV_VAR
AERON_DIR_ENV_VAR
AERON_DIR_WARN_IF_EXISTS_ENV_VAR
AERON_DRIVER_CONDUCTOR_CLOCK_UPDATE_DURATION_NS
AERON_DRIVER_CONDUCTOR_LINGER_RESOURCE_TIMEOUT_NS
AERON_DRIVER_RECEIVER_MAX_UDP_PACKET_LENGTH
AERON_DRIVER_RECEIVER_NUM_RECV_BUFFERS
AERON_DRIVER_RECEIVER_PENDING_SETUP_TIMEOUT_NS
AERON_DRIVER_RERESOLUTION_CHECK_INTERVAL_ENV_VAR
AERON_DRIVER_RESOLVER_BOOTSTRAP_NEIGHBOR_ENV_VAR
AERON_DRIVER_RESOLVER_INTERFACE_ENV_VAR
AERON_DRIVER_RESOLVER_NAME_ENV_VAR
AERON_DRIVER_SENDER_NUM_RECV_BUFFERS
AERON_DRIVER_TERMINATION_VALIDATOR_ENV_VAR
AERON_DRIVER_TIMEOUT_ENV_VAR
AERON_ERROR_BUFFER_LENGTH_ENV_VAR
AERON_ERROR_CODE_CHANNEL_ENDPOINT_ERROR
AERON_ERROR_CODE_GENERIC_ERROR
AERON_ERROR_CODE_INVALID_CHANNEL
AERON_ERROR_CODE_MALFORMED_COMMAND
AERON_ERROR_CODE_NOT_SUPPORTED
AERON_ERROR_CODE_RESOURCE_TEMPORARILY_UNAVAILABLE
AERON_ERROR_CODE_UNKNOWN_CODE_VALUE
AERON_ERROR_CODE_UNKNOWN_COMMAND_TYPE_ID
AERON_ERROR_CODE_UNKNOWN_COUNTER
AERON_ERROR_CODE_UNKNOWN_HOST
AERON_ERROR_CODE_UNKNOWN_PUBLICATION
AERON_ERROR_CODE_UNKNOWN_SUBSCRIPTION
AERON_FILE_PAGE_SIZE_ENV_VAR
AERON_FLOW_CONTROL_GROUP_MIN_SIZE_ENV_VAR
AERON_FLOW_CONTROL_GROUP_TAG_ENV_VAR
AERON_FRAME_HEADER_VERSION
AERON_FRAME_MAX_MESSAGE_LENGTH
AERON_HDR_TYPE_DATA
AERON_HDR_TYPE_ERR
AERON_HDR_TYPE_EXT
AERON_HDR_TYPE_NAK
AERON_HDR_TYPE_PAD
AERON_HDR_TYPE_RES
AERON_HDR_TYPE_RTTM
AERON_HDR_TYPE_SETUP
AERON_HDR_TYPE_SM
AERON_IDLE_STRATEGY_BACKOFF_MAX_PARK_PERIOD_NS
AERON_IDLE_STRATEGY_BACKOFF_MAX_SPINS
AERON_IDLE_STRATEGY_BACKOFF_MAX_YIELDS
AERON_IDLE_STRATEGY_BACKOFF_MIN_PARK_PERIOD_NS
AERON_IMAGES_DIR
AERON_IMAGE_LIVENESS_TIMEOUT_ENV_VAR
AERON_INIT_ONCE_VALUE
AERON_IPC_CHANNEL
AERON_IPC_MTU_LENGTH_ENV_VAR
AERON_IPC_PUBLICATION_TERM_WINDOW_LENGTH_ENV_VAR
AERON_IPC_TERM_BUFFER_LENGTH_ENV_VAR
AERON_LOGBUFFER_DEFAULT_FRAME_HEADER_MAX_LENGTH
AERON_LOGBUFFER_FRAME_ALIGNMENT
AERON_LOGBUFFER_PARTITION_COUNT
AERON_LOGBUFFER_TERM_MAX_LENGTH
AERON_LOGBUFFER_TERM_MIN_LENGTH
AERON_LOG_META_DATA_SECTION_INDEX
AERON_LOSS_DETECTOR_NAK_MULTICAST_GROUP_SIZE
AERON_LOSS_DETECTOR_NAK_MULTICAST_MAX_BACKOFF_NS
AERON_LOSS_DETECTOR_NAK_UNICAST_DELAY_NS
AERON_LOSS_DETECTOR_TIMER_INACTIVE
AERON_LOSS_REPORTER_ENTRY_ALIGNMENT
AERON_LOSS_REPORT_BUFFER_LENGTH_ENV_VAR
AERON_LOSS_REPORT_FILE
AERON_MAP_DEFAULT_LOAD_FACTOR
AERON_MAX_FLOW_CONTROL_STRATEGY_NAME
AERON_MAX_PATH
AERON_MAX_UDP_PAYLOAD_LENGTH
AERON_MIN_FLOW_CONTROL_STRATEGY_NAME
AERON_MIN_MULTICAST_FLOW_CONTROL_RECEIVER_TIMEOUT_ENV_VAR
AERON_MTU_LENGTH_ENV_VAR
AERON_MULTICAST_FLOWCONTROL_SUPPLIER_ENV_VAR
AERON_MULTICAST_MAX_FLOW_CONTROL_STRATEGY_NAME
AERON_MULTICAST_MIN_FLOW_CONTROL_STRATEGY_NAME
AERON_MULTICAST_TAGGED_FLOW_CONTROL_STRATEGY_NAME
AERON_NAK_MULTICAST_GROUP_SIZE_ENV_VAR
AERON_NAK_MULTICAST_MAX_BACKOFF_ENV_VAR
AERON_NAK_UNICAST_DELAY_ENV_VAR
AERON_NAME_RESOLVER_CSV_TABLE
AERON_NAME_RESOLVER_CSV_TABLE_ARGS_ENV_VAR
AERON_NAME_RESOLVER_DRIVER
AERON_NAME_RESOLVER_INIT_ARGS_ENV_VAR
AERON_NAME_RESOLVER_SUPPLIER_DEFAULT
AERON_NAME_RESOLVER_SUPPLIER_ENV_VAR
AERON_NETUTIL_FORMATTED_MAX_LENGTH
AERON_NETWORK_PUBLICATION_HEARTBEAT_TIMEOUT_NS
AERON_NETWORK_PUBLICATION_MAX_MESSAGES_PER_SEND
AERON_NETWORK_PUBLICATION_SETUP_TIMEOUT_NS
AERON_NULL_COUNTER_ID
AERON_NULL_VALUE
AERON_PAGE_MAX_SIZE
AERON_PAGE_MIN_SIZE
AERON_PERFORM_STORAGE_CHECKS_ENV_VAR
AERON_PRINT_CONFIGURATION_ON_START_ENV_VAR
AERON_PUBLICATIONS_DIR
AERON_PUBLICATION_ADMIN_ACTION
AERON_PUBLICATION_BACK_PRESSURED
AERON_PUBLICATION_CLOSED
AERON_PUBLICATION_CONNECTION_TIMEOUT_ENV_VAR
AERON_PUBLICATION_ERROR
AERON_PUBLICATION_LINGER_TIMEOUT_ENV_VAR
AERON_PUBLICATION_MAX_POSITION_EXCEEDED
AERON_PUBLICATION_NOT_CONNECTED
AERON_PUBLICATION_RESERVED_SESSION_ID_HIGH_ENV_VAR
AERON_PUBLICATION_RESERVED_SESSION_ID_LOW_ENV_VAR
AERON_PUBLICATION_TERM_WINDOW_LENGTH_ENV_VAR
AERON_PUBLICATION_UNBLOCK_TIMEOUT_ENV_VAR
AERON_RB_PADDING_MSG_TYPE_ID
AERON_RCV_INITIAL_WINDOW_LENGTH_ENV_VAR
AERON_RCV_STATUS_MESSAGE_TIMEOUT_ENV_VAR
AERON_RECEIVER_GROUP_CONSIDERATION_ENV_VAR
AERON_RECEIVER_GROUP_TAG_ENV_VAR
AERON_RECEIVER_IDLE_STRATEGY_ENV_VAR
AERON_RECEIVER_IDLE_STRATEGY_INIT_ARGS_ENV_VAR
AERON_RECEIVE_DESTINATION_TIMEOUT_NS
AERON_REJOIN_STREAM_ENV_VAR
AERON_RELIABLE_STREAM_ENV_VAR
AERON_RESPONSE_ON_AVAILABLE_IMAGE
AERON_RESPONSE_ON_CLIENT_TIMEOUT
AERON_RESPONSE_ON_COUNTER_READY
AERON_RESPONSE_ON_ERROR
AERON_RESPONSE_ON_EXCLUSIVE_PUBLICATION_READY
AERON_RESPONSE_ON_OPERATION_SUCCESS
AERON_RESPONSE_ON_PUBLICATION_READY
AERON_RESPONSE_ON_SUBSCRIPTION_READY
AERON_RESPONSE_ON_UNAVAILABLE_COUNTER
AERON_RESPONSE_ON_UNAVAILABLE_IMAGE
AERON_RES_HEADER_ADDRESS_LENGTH_IP4
AERON_RES_HEADER_ADDRESS_LENGTH_IP6
AERON_RES_HEADER_TYPE_NAME_TO_IP4_MD
AERON_RES_HEADER_TYPE_NAME_TO_IP6_MD
AERON_RETRANSMIT_HANDLER_MAX_RETRANSMITS
AERON_RETRANSMIT_UNICAST_DELAY_ENV_VAR
AERON_RETRANSMIT_UNICAST_LINGER_ENV_VAR
AERON_SENDER_IDLE_STRATEGY_ENV_VAR
AERON_SENDER_IDLE_STRATEGY_INIT_ARGS_ENV_VAR
AERON_SEND_CHANNEL_ENDPOINT_DESTINATION_TIMEOUT_NS
AERON_SEND_TO_STATUS_POLL_RATIO_ENV_VAR
AERON_SHAREDNETWORK_IDLE_STRATEGY_ENV_VAR
AERON_SHAREDNETWORK_IDLE_STRATEGY_INIT_ARGS_ENV_VAR
AERON_SHARED_IDLE_STRATEGY_ENV_INIT_ARGS_VAR
AERON_SHARED_IDLE_STRATEGY_ENV_VAR
AERON_SOCKET_MULTICAST_TTL_ENV_VAR
AERON_SOCKET_SO_RCVBUF_ENV_VAR
AERON_SOCKET_SO_SNDBUF_ENV_VAR
AERON_SPIES_SIMULATE_CONNECTION_ENV_VAR
AERON_SPY_PREFIX
AERON_SYSTEM_COUNTER_TYPE_ID
AERON_TAGGED_FLOW_CONTROL_STRATEGY_NAME
AERON_TERM_BUFFER_LENGTH_ENV_VAR
AERON_TERM_BUFFER_SPARSE_FILE_ENV_VAR
AERON_TETHER_SUBSCRIPTIONS_ENV_VAR
AERON_THREADING_MODE_ENV_VAR
AERON_TIMER_INTERVAL_ENV_VAR
AERON_TO_CLIENTS_BUFFER_LENGTH_ENV_VAR
AERON_TO_CONDUCTOR_BUFFER_LENGTH_ENV_VAR
AERON_UDP_CHANNEL_CONTROL_KEY
AERON_UDP_CHANNEL_CONTROL_MODE_DYNAMIC_VALUE
AERON_UDP_CHANNEL_CONTROL_MODE_KEY
AERON_UDP_CHANNEL_CONTROL_MODE_MANUAL_VALUE
AERON_UDP_CHANNEL_ENDPOINT_KEY
AERON_UDP_CHANNEL_INCOMING_INTERCEPTORS_ENV_VAR
AERON_UDP_CHANNEL_INTERFACE_KEY
AERON_UDP_CHANNEL_OUTGOING_INTERCEPTORS_ENV_VAR
AERON_UDP_CHANNEL_RELIABLE_KEY
AERON_UDP_CHANNEL_TRANSPORT_BINDINGS_MEDIA_ENV_VAR
AERON_UDP_CHANNEL_TTL_KEY
AERON_UDP_DESTINATION_TRACKER_DESTINATION_TIMEOUT_NS
AERON_UDP_TRANSPORT_POLLER_ITERATION_THRESHOLD
AERON_UNICAST_FLOWCONTROL_SUPPLIER_ENV_VAR
AERON_UNICAST_MAX_FLOW_CONTROL_STRATEGY_NAME
AERON_UNTETHERED_RESTING_TIMEOUT_ENV_VAR
AERON_UNTETHERED_WINDOW_LIMIT_TIMEOUT_ENV_VAR
AERON_URI_CC_KEY
AERON_URI_EOS_KEY
AERON_URI_FC_KEY
AERON_URI_GROUP_KEY
AERON_URI_GTAG_KEY
AERON_URI_INITIAL_TERM_ID_KEY
AERON_URI_INVALID_TAG
AERON_URI_LINGER_TIMEOUT_KEY
AERON_URI_MTU_LENGTH_KEY
AERON_URI_REJOIN_KEY
AERON_URI_SESSION_ID_KEY
AERON_URI_SPARSE_TERM_KEY
AERON_URI_TAGS_KEY
AERON_URI_TERM_ID_KEY
AERON_URI_TERM_LENGTH_KEY
AERON_URI_TERM_OFFSET_KEY
AERON_URI_TETHER_KEY
aeron_controlled_fragment_handler_action_en_AERON_ACTION_ABORT

Abort the current polling operation and do not advance the position for this fragment.

aeron_controlled_fragment_handler_action_en_AERON_ACTION_BREAK

Break from the current polling operation and commit the position as of the end of the current fragment being handled.

aeron_controlled_fragment_handler_action_en_AERON_ACTION_COMMIT

Continue processing but commit the position as of the end of the current fragment so that flow control is applied to this point.

aeron_controlled_fragment_handler_action_en_AERON_ACTION_CONTINUE

Continue processing until fragment limit or no fragments with position commit at end of poll as in aeron_fragment_handler_t.

aeron_queue_offer_result_stct_AERON_OFFER_ERROR
aeron_queue_offer_result_stct_AERON_OFFER_FULL
aeron_queue_offer_result_stct_AERON_OFFER_SUCCESS
aeron_rb_write_result_stct_AERON_RB_ERROR
aeron_rb_write_result_stct_AERON_RB_FULL
aeron_rb_write_result_stct_AERON_RB_SUCCESS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_BYTES_RECEIVED
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_BYTES_SENT
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_CLIENT_TIMEOUTS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_CONDUCTOR_PROXY_FAILS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_CONTROLLABLE_IDLE_STRATEGY
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_DUMMY_LAST
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_ERRORS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_FLOW_CONTROL_OVER_RUNS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_FLOW_CONTROL_UNDER_RUNS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_FREE_FAILS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_HEARTBEATS_RECEIVED
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_HEARTBEATS_SENT
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_INVALID_PACKETS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_LOSS_GAP_FILLS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_NAK_MESSAGES_RECEIVED
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_NAK_MESSAGES_SENT
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_POSSIBLE_TTL_ASYMMETRY
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_RECEIVER_PROXY_FAILS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_RESOLUTION_CHANGES
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_RETRANSMITS_SENT
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_SENDER_FLOW_CONTROL_LIMITS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_SENDER_PROXY_FAILS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_SHORT_SENDS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_STATUS_MESSAGES_RECEIVED
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_STATUS_MESSAGES_SENT
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_UNBLOCKED_COMMANDS
aeron_system_counter_enum_stct_AERON_SYSTEM_COUNTER_UNBLOCKED_PUBLICATIONS
aeron_udp_channel_transport_affinity_en_AERON_UDP_CHANNEL_TRANSPORT_AFFINITY_CONDUCTOR
aeron_udp_channel_transport_affinity_en_AERON_UDP_CHANNEL_TRANSPORT_AFFINITY_RECEIVER
aeron_udp_channel_transport_affinity_en_AERON_UDP_CHANNEL_TRANSPORT_AFFINITY_SENDER

Functions

aeron_add_available_counter_handler
aeron_add_close_handler
aeron_add_unavailable_counter_handler
aeron_agent_close
aeron_agent_init
aeron_agent_on_start_load
aeron_agent_start
aeron_agent_stop
aeron_alloc
aeron_alloc_aligned
aeron_alloc_no_err
aeron_async_add_counter

Asynchronously add a counter using the given client and return an object to use to determine when the counter is available.

aeron_async_add_counter_poll

Poll the completion of the aeron_async_add_counter call.

aeron_async_add_exclusive_publication

Asynchronously add an exclusive publication using the given client and return an object to use to determine when the publication is available.

aeron_async_add_exclusive_publication_poll

Poll the completion of the aeron_async_add_exclusive_publication call.

aeron_async_add_publication

Asynchronously add a publication using the given client and return an object to use to determine when the publication is available.

aeron_async_add_publication_poll

Poll the completion of the aeron_async_add_publication call.

aeron_async_add_subscription

Asynchronously add a subscription using the given client and return an object to use to determine when the subscription is available.

aeron_async_add_subscription_poll

Poll the completion of the aeron_async_add_subscription call.

aeron_broadcast_transmitter_init
aeron_broadcast_transmitter_transmit
aeron_buffer_claim_abort

Abort the given buffer_claim and assign its position as padding.

aeron_buffer_claim_commit

Commit the given buffer_claim as a complete message available for consumption.

aeron_client_delete
aeron_client_has_reached_end_of_life
aeron_client_id

Return the client id in use by the client.

aeron_client_on_time_event
aeron_clock_cache_alloc

Allocate a cached clock @param cached_time Pointer to the pointer to be initialised with the new cached clock @return -1 if allocation fails, e.g. out of memory.

aeron_clock_cache_free

Free a cached clock. @param cached_time

aeron_clock_cached_epoch_time

Retrieves the cached epoch time from supplied cached clock. @param cached_time 'this' @return The current cached value for the epoch time.

aeron_clock_cached_nano_time

Retrieves the cached nano time from supplied cached clock. @param cached_time 'this' @return The current cached value for the nano time.

aeron_clock_update_cached_time

Update the cached clock with the current epoch and nano time values.

aeron_close

Close and delete aeron_t struct.

aeron_close_socket
aeron_cnc_length
aeron_cnc_version_volatile
aeron_command_on_delete_cmd
aeron_conductor_proxy_on_delete_send_destination
aeron_config_parse_inferable_boolean
aeron_congestion_control_strategy_supplier_load
aeron_context

Return the aeron_context_t that is in use by the given client.

aeron_context_close

Close and delete aeron_context_t struct.

aeron_context_get_agent_on_start_function
aeron_context_get_agent_on_start_state
aeron_context_get_dir
aeron_context_get_driver_timeout_ms
aeron_context_get_error_handler
aeron_context_get_error_handler_clientd
aeron_context_get_keepalive_interval_ns
aeron_context_get_on_new_exclusive_publication
aeron_context_get_on_new_exclusive_publication_clientd
aeron_context_get_on_new_publication
aeron_context_get_on_new_publication_clientd
aeron_context_get_on_new_subscription
aeron_context_get_on_new_subscription_clientd
aeron_context_get_resource_linger_duration_ns
aeron_context_get_use_conductor_agent_invoker
aeron_context_init

Create a aeron_context_t struct and initialize with default values.

aeron_context_set_agent_on_start_function
aeron_context_set_dir
aeron_context_set_driver_timeout_ms
aeron_context_set_error_handler
aeron_context_set_keepalive_interval_ns
aeron_context_set_on_new_exclusive_publication
aeron_context_set_on_new_publication
aeron_context_set_on_new_subscription
aeron_context_set_resource_linger_duration_ns
aeron_context_set_use_conductor_agent_invoker

Whether to use an invoker to control the conductor agent or spawn a thread.

aeron_controlled_fragment_assembler_create

Create a controlled fragment assembler for use with a subscription.

aeron_controlled_fragment_assembler_delete

Delete a controlled fragment assembler.

aeron_controlled_fragment_assembler_handler

Handler function to be passed for handling fragment assembly.

aeron_controlled_image_fragment_assembler_handler

Handler function to be passed for handling fragment assembly.

aeron_counter_addr

Return a pointer to the counter value.

aeron_counter_close

Asynchronously close the counter.

aeron_counters_manager_allocate
aeron_counters_manager_close
aeron_counters_manager_free
aeron_counters_manager_init
aeron_counters_manager_next_counter_id
aeron_counters_manager_update_label
aeron_counters_reader

Return a reference to the counters reader of the given client.

aeron_counters_reader_foreach_counter

Iterate over the coounters in the counters_reader and call the given function for each counter.

aeron_counters_reader_foreach_metadata
aeron_data_packet_dispatcher_add_publication_image
aeron_data_packet_dispatcher_add_subscription
aeron_data_packet_dispatcher_add_subscription_by_session
aeron_data_packet_dispatcher_close
aeron_data_packet_dispatcher_elicit_setup_from_source
aeron_data_packet_dispatcher_init
aeron_data_packet_dispatcher_on_data
aeron_data_packet_dispatcher_on_rttm
aeron_data_packet_dispatcher_on_setup
aeron_data_packet_dispatcher_remove_publication_image
aeron_data_packet_dispatcher_remove_subscription
aeron_data_packet_dispatcher_remove_subscription_by_session
aeron_default_multicast_flow_control_strategy_supplier
aeron_default_name_resolver_close
aeron_default_name_resolver_do_work
aeron_default_name_resolver_lookup
aeron_default_name_resolver_resolve
aeron_default_name_resolver_supplier
aeron_delete_directory

Delete the given aeron directory.

aeron_distinct_error_log_close
aeron_distinct_error_log_init
aeron_distinct_error_log_num_observations
aeron_distinct_error_log_record
aeron_driver_close

Close and delete aeron_driver_t struct.

aeron_driver_conductor_cleanup_network_publication
aeron_driver_conductor_cleanup_spies
aeron_driver_conductor_client_transmit
aeron_driver_conductor_do_work
aeron_driver_conductor_find_receive_channel_endpoint_by_tag
aeron_driver_conductor_find_send_channel_endpoint_by_tag
aeron_driver_conductor_image_transition_to_linger
aeron_driver_conductor_init
aeron_driver_conductor_link_subscribable
aeron_driver_conductor_on_add_counter
aeron_driver_conductor_on_add_destination
aeron_driver_conductor_on_add_ipc_publication
aeron_driver_conductor_on_add_ipc_subscription
aeron_driver_conductor_on_add_network_publication
aeron_driver_conductor_on_add_network_subscription
aeron_driver_conductor_on_add_receive_destination
aeron_driver_conductor_on_add_spy_subscription
aeron_driver_conductor_on_available_image
aeron_driver_conductor_on_client_close
aeron_driver_conductor_on_client_keepalive
aeron_driver_conductor_on_client_timeout
aeron_driver_conductor_on_close
aeron_driver_conductor_on_command
aeron_driver_conductor_on_counter_ready
aeron_driver_conductor_on_create_publication_image
aeron_driver_conductor_on_delete_receive_destination
aeron_driver_conductor_on_delete_send_destination
aeron_driver_conductor_on_linger_buffer
aeron_driver_conductor_on_re_resolve_control
aeron_driver_conductor_on_re_resolve_endpoint
aeron_driver_conductor_on_receive_endpoint_removed
aeron_driver_conductor_on_remove_counter
aeron_driver_conductor_on_remove_destination
aeron_driver_conductor_on_remove_publication
aeron_driver_conductor_on_remove_receive_destination
aeron_driver_conductor_on_remove_subscription
aeron_driver_conductor_on_terminate_driver
aeron_driver_conductor_on_unavailable_counter
aeron_driver_conductor_on_unavailable_image
aeron_driver_conductor_proxy_on_create_publication_image_cmd
aeron_driver_conductor_proxy_on_delete_cmd
aeron_driver_conductor_proxy_on_delete_receive_destination
aeron_driver_conductor_proxy_on_linger_buffer
aeron_driver_conductor_proxy_on_re_resolve_control
aeron_driver_conductor_proxy_on_re_resolve_endpoint
aeron_driver_conductor_proxy_on_receive_endpoint_removed
aeron_driver_conductor_unlink_all_subscribable
aeron_driver_conductor_unlink_subscribable
aeron_driver_context_close

Close and delete aeron_driver_context_t struct.

aeron_driver_context_get_agent_on_start_function
aeron_driver_context_get_agent_on_start_state
aeron_driver_context_get_client_liveness_timeout_ns
aeron_driver_context_get_conductor_idle_strategy
aeron_driver_context_get_conductor_idle_strategy_init_args
aeron_driver_context_get_congestioncontrol_supplier
aeron_driver_context_get_counters_buffer_length
aeron_driver_context_get_counters_free_to_reuse_timeout_ns
aeron_driver_context_get_dir
aeron_driver_context_get_dir_delete_on_shutdown
aeron_driver_context_get_dir_delete_on_start
aeron_driver_context_get_dir_warn_if_exists
aeron_driver_context_get_driver_termination_hook
aeron_driver_context_get_driver_termination_hook_state
aeron_driver_context_get_driver_termination_validator
aeron_driver_context_get_driver_termination_validator_state
aeron_driver_context_get_driver_timeout_ms
aeron_driver_context_get_error_buffer_length
aeron_driver_context_get_file_page_size
aeron_driver_context_get_flow_control_group_min_size
aeron_driver_context_get_flow_control_group_tag
aeron_driver_context_get_flow_control_receiver_timeout_ns
aeron_driver_context_get_image_liveness_timeout_ns
aeron_driver_context_get_ipc_mtu_length
aeron_driver_context_get_ipc_publication_term_window_length
aeron_driver_context_get_ipc_term_buffer_length
aeron_driver_context_get_loss_report_buffer_length
aeron_driver_context_get_mtu_length
aeron_driver_context_get_multicast_flowcontrol_supplier
aeron_driver_context_get_nak_multicast_group_size
aeron_driver_context_get_nak_multicast_max_backoff_ns
aeron_driver_context_get_nak_unicast_delay_ns
aeron_driver_context_get_name_resolver_init_args
aeron_driver_context_get_name_resolver_supplier
aeron_driver_context_get_perform_storage_checks
aeron_driver_context_get_print_configuration
aeron_driver_context_get_publication_connection_timeout_ns
aeron_driver_context_get_publication_linger_timeout_ns
aeron_driver_context_get_publication_reserved_session_id_high
aeron_driver_context_get_publication_reserved_session_id_low
aeron_driver_context_get_publication_term_window_length
aeron_driver_context_get_publication_unblock_timeout_ns
aeron_driver_context_get_rcv_initial_window_length
aeron_driver_context_get_rcv_status_message_timeout_ns
aeron_driver_context_get_re_resolution_check_interval_ns
aeron_driver_context_get_receiver_group_consideration
aeron_driver_context_get_receiver_group_tag_is_present
aeron_driver_context_get_receiver_group_tag_value
aeron_driver_context_get_receiver_idle_strategy
aeron_driver_context_get_receiver_idle_strategy_init_args
aeron_driver_context_get_rejoin_stream
aeron_driver_context_get_reliable_stream
aeron_driver_context_get_resolver_bootstrap_neighbor
aeron_driver_context_get_resolver_interface
aeron_driver_context_get_resolver_name
aeron_driver_context_get_retransmit_unicast_delay_ns
aeron_driver_context_get_retransmit_unicast_linger_ns
aeron_driver_context_get_send_to_status_poll_ratio
aeron_driver_context_get_sender_idle_strategy
aeron_driver_context_get_sender_idle_strategy_init_args
aeron_driver_context_get_shared_idle_strategy
aeron_driver_context_get_shared_idle_strategy_init_args
aeron_driver_context_get_sharednetwork_idle_strategy
aeron_driver_context_get_sharednetwork_idle_strategy_init_args
aeron_driver_context_get_socket_multicast_ttl
aeron_driver_context_get_socket_so_rcvbuf
aeron_driver_context_get_socket_so_sndbuf
aeron_driver_context_get_spies_simulate_connection
aeron_driver_context_get_term_buffer_length
aeron_driver_context_get_term_buffer_sparse_file
aeron_driver_context_get_tether_subscriptions
aeron_driver_context_get_threading_mode
aeron_driver_context_get_timer_interval_ns
aeron_driver_context_get_to_clients_buffer_length
aeron_driver_context_get_to_conductor_buffer_length
aeron_driver_context_get_udp_channel_incoming_interceptors
aeron_driver_context_get_udp_channel_outgoing_interceptors
aeron_driver_context_get_udp_channel_transport_bindings
aeron_driver_context_get_unicast_flowcontrol_supplier
aeron_driver_context_get_untethered_resting_timeout_ns
aeron_driver_context_get_untethered_window_limit_timeout_ns
aeron_driver_context_init

Create a aeron_driver_context_t struct and initialize with default values.

aeron_driver_context_print_configuration
aeron_driver_context_set_agent_on_start_function
aeron_driver_context_set_client_liveness_timeout_ns
aeron_driver_context_set_conductor_idle_strategy
aeron_driver_context_set_conductor_idle_strategy_init_args
aeron_driver_context_set_congestioncontrol_supplier
aeron_driver_context_set_counters_buffer_length
aeron_driver_context_set_counters_free_to_reuse_timeout_ns
aeron_driver_context_set_dir
aeron_driver_context_set_dir_delete_on_shutdown
aeron_driver_context_set_dir_delete_on_start
aeron_driver_context_set_dir_warn_if_exists
aeron_driver_context_set_driver_termination_hook
aeron_driver_context_set_driver_termination_validator
aeron_driver_context_set_driver_timeout_ms
aeron_driver_context_set_error_buffer_length
aeron_driver_context_set_file_page_size
aeron_driver_context_set_flow_control_group_min_size
aeron_driver_context_set_flow_control_group_tag
aeron_driver_context_set_flow_control_receiver_timeout_ns
aeron_driver_context_set_image_liveness_timeout_ns
aeron_driver_context_set_ipc_mtu_length
aeron_driver_context_set_ipc_publication_term_window_length
aeron_driver_context_set_ipc_term_buffer_length
aeron_driver_context_set_loss_report_buffer_length
aeron_driver_context_set_mtu_length
aeron_driver_context_set_multicast_flowcontrol_supplier
aeron_driver_context_set_nak_multicast_group_size
aeron_driver_context_set_nak_multicast_max_backoff_ns
aeron_driver_context_set_nak_unicast_delay_ns
aeron_driver_context_set_name_resolver_init_args
aeron_driver_context_set_name_resolver_supplier
aeron_driver_context_set_perform_storage_checks
aeron_driver_context_set_print_configuration
aeron_driver_context_set_publication_connection_timeout_ns
aeron_driver_context_set_publication_linger_timeout_ns
aeron_driver_context_set_publication_reserved_session_id_high
aeron_driver_context_set_publication_reserved_session_id_low
aeron_driver_context_set_publication_term_window_length
aeron_driver_context_set_publication_unblock_timeout_ns
aeron_driver_context_set_rcv_initial_window_length
aeron_driver_context_set_rcv_status_message_timeout_ns
aeron_driver_context_set_re_resolution_check_interval_ns
aeron_driver_context_set_receiver_group_consideration
aeron_driver_context_set_receiver_group_tag
aeron_driver_context_set_receiver_idle_strategy
aeron_driver_context_set_receiver_idle_strategy_init_args
aeron_driver_context_set_rejoin_stream
aeron_driver_context_set_reliable_stream
aeron_driver_context_set_resolver_bootstrap_neighbor
aeron_driver_context_set_resolver_interface
aeron_driver_context_set_resolver_name
aeron_driver_context_set_retransmit_unicast_delay_ns
aeron_driver_context_set_retransmit_unicast_linger_ns
aeron_driver_context_set_send_to_status_poll_ratio
aeron_driver_context_set_sender_idle_strategy
aeron_driver_context_set_sender_idle_strategy_init_args
aeron_driver_context_set_shared_idle_strategy
aeron_driver_context_set_shared_idle_strategy_init_args
aeron_driver_context_set_sharednetwork_idle_strategy
aeron_driver_context_set_sharednetwork_idle_strategy_init_args
aeron_driver_context_set_socket_multicast_ttl
aeron_driver_context_set_socket_so_rcvbuf
aeron_driver_context_set_socket_so_sndbuf
aeron_driver_context_set_spies_simulate_connection
aeron_driver_context_set_term_buffer_length
aeron_driver_context_set_term_buffer_sparse_file
aeron_driver_context_set_tether_subscriptions
aeron_driver_context_set_threading_mode
aeron_driver_context_set_timer_interval_ns
aeron_driver_context_set_to_clients_buffer_length
aeron_driver_context_set_to_conductor_buffer_length
aeron_driver_context_set_udp_channel_incoming_interceptors
aeron_driver_context_set_udp_channel_outgoing_interceptors
aeron_driver_context_set_udp_channel_transport_bindings
aeron_driver_context_set_unicast_flowcontrol_supplier
aeron_driver_context_set_untethered_resting_timeout_ns
aeron_driver_context_set_untethered_window_limit_timeout_ns
aeron_driver_context_validate_mtu_length
aeron_driver_fill_cnc_metadata
aeron_driver_init

Create a aeron_driver_t struct and initialize from the aeron_driver_context_t struct.

aeron_driver_main_do_work

Call the Conductor (or Shared) main do_work duty cycle once.

aeron_driver_main_idle_strategy

Call the Conductor (or Shared) Idle Strategy.

aeron_driver_receiver_add_pending_setup
aeron_driver_receiver_do_work
aeron_driver_receiver_init
aeron_driver_receiver_on_add_destination
aeron_driver_receiver_on_add_endpoint
aeron_driver_receiver_on_add_publication_image
aeron_driver_receiver_on_add_subscription
aeron_driver_receiver_on_add_subscription_by_session
aeron_driver_receiver_on_close
aeron_driver_receiver_on_remove_cool_down
aeron_driver_receiver_on_remove_destination
aeron_driver_receiver_on_remove_endpoint
aeron_driver_receiver_on_remove_publication_image
aeron_driver_receiver_on_remove_subscription
aeron_driver_receiver_on_remove_subscription_by_session
aeron_driver_receiver_on_resolution_change
aeron_driver_receiver_proxy_on_add_destination
aeron_driver_receiver_proxy_on_add_endpoint
aeron_driver_receiver_proxy_on_add_publication_image
aeron_driver_receiver_proxy_on_add_subscription
aeron_driver_receiver_proxy_on_add_subscription_by_session
aeron_driver_receiver_proxy_on_delete_cmd
aeron_driver_receiver_proxy_on_remove_cool_down
aeron_driver_receiver_proxy_on_remove_destination
aeron_driver_receiver_proxy_on_remove_endpoint
aeron_driver_receiver_proxy_on_remove_publication_image
aeron_driver_receiver_proxy_on_remove_subscription
aeron_driver_receiver_proxy_on_remove_subscription_by_session
aeron_driver_receiver_proxy_on_resolution_change
aeron_driver_sender_do_send
aeron_driver_sender_do_work
aeron_driver_sender_init
aeron_driver_sender_on_add_destination
aeron_driver_sender_on_add_endpoint
aeron_driver_sender_on_add_publication
aeron_driver_sender_on_close
aeron_driver_sender_on_remove_destination
aeron_driver_sender_on_remove_endpoint
aeron_driver_sender_on_remove_publication
aeron_driver_sender_on_resolution_change
aeron_driver_sender_proxy_on_add_destination
aeron_driver_sender_proxy_on_add_endpoint
aeron_driver_sender_proxy_on_add_publication
aeron_driver_sender_proxy_on_delete_cmd
aeron_driver_sender_proxy_on_remove_destination
aeron_driver_sender_proxy_on_remove_endpoint
aeron_driver_sender_proxy_on_remove_publication
aeron_driver_sender_proxy_on_resolution_change
aeron_driver_start

Start an aeron_driver_t given the threading mode. This may spawn threads for the Sender, Receiver, and Conductor depending on threading mode used.

aeron_driver_subscribable_remove_position
aeron_epoch_clock

Return time in milliseconds since epoch. Is wall clock time.

aeron_errcode

Return current aeron error code (errno) for calling thread.

aeron_errmsg

Return the current aeron error message for calling thread.

aeron_error_code_str
aeron_error_log_exists
aeron_error_log_read
aeron_exclusive_publication_add_destination

Add a destination manually to a multi-destination-cast publication.

aeron_exclusive_publication_append_padding

Append a padding record log of a given length to make up the log to a position.

aeron_exclusive_publication_channel_status
aeron_exclusive_publication_close

Asynchronously close the publication.

aeron_exclusive_publication_offer

Non-blocking publish of a buffer containing a message.

aeron_exclusive_publication_offer_block

Offer a block of pre-formatted message fragments directly into the current term.

aeron_exclusive_publication_offerv

Non-blocking publish by gathering buffer vectors into a message.

aeron_exclusive_publication_remove_destination

Remove a previously added destination manually from a multi-destination-cast publication.

aeron_exclusive_publication_try_claim
aeron_feedback_delay_state_init
aeron_file_length
aeron_find_interface
aeron_find_unicast_interface
aeron_flow_control_parse_tagged_options
aeron_flow_control_strategy_has_required_receivers_default
aeron_flow_control_strategy_supplier_by_name

Return a flow control strategy supplier function pointer associated with the given name. This only will find strategies built into the driver and will not try to dynamically load nor find any in the current executable.

aeron_flow_control_strategy_supplier_load
aeron_format_date
aeron_format_source_identity
aeron_format_to_hex
aeron_fragment_assembler_create

Create a fragment assembler for use with a subscription.

aeron_fragment_assembler_delete

Delete a fragment assembler.

aeron_fragment_assembler_handler

Handler function to be passed for handling fragment assembly.

aeron_free
aeron_getsockopt
aeron_idle_strategy_backoff_idle
aeron_idle_strategy_backoff_state_init
aeron_idle_strategy_busy_spinning_idle
aeron_idle_strategy_init_null
aeron_idle_strategy_load
aeron_idle_strategy_noop_idle
aeron_idle_strategy_sleeping_idle
aeron_idle_strategy_yielding_idle
aeron_image_block_poll

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of bytes.

aeron_image_bounded_controlled_poll

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of fragments as specified or the maximum position specified.

aeron_image_bounded_poll

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of fragments as specified or the maximum position specified.

aeron_image_controlled_fragment_assembler_create

Create an image controlled fragment assembler for use with a single image.

aeron_image_controlled_fragment_assembler_delete

Delete an image controlled fragment assembler.

aeron_image_controlled_peek

Peek for new messages in a stream by scanning forward from an initial position. If new messages are found then they will be delivered to the handler up to a limited position.

aeron_image_controlled_poll

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of fragments as specified.

aeron_image_fragment_assembler_create

Create an image fragment assembler for use with a single image.

aeron_image_fragment_assembler_delete

Delete an image fragment assembler.

aeron_image_fragment_assembler_handler

Handler function to be passed for handling fragment assembly.

aeron_image_is_closed
aeron_image_poll

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of fragments as specified.

aeron_image_position

The position this image has been consumed to by the subscriber.

aeron_image_release

Release the given image and relinquish desire to use the image directly.

aeron_image_retain

Retain the given image for access in the application.

aeron_image_set_position

Set the subscriber position for this image to indicate where it has been consumed to.

aeron_init

Create a aeron_t client struct and initialize from the aeron_context_t struct.

aeron_interface_parse_and_resolve
aeron_ip_addr_resolver
aeron_ipc_publication_check_for_blocked_publisher
aeron_ipc_publication_clean_buffer
aeron_ipc_publication_close
aeron_ipc_publication_create
aeron_ipc_publication_decref
aeron_ipc_publication_entry_delete
aeron_ipc_publication_entry_has_reached_end_of_life
aeron_ipc_publication_entry_on_time_event
aeron_ipc_publication_incref
aeron_ipc_publication_location
aeron_ipc_publication_on_time_event
aeron_ipc_publication_update_pub_lmt
aeron_ipc_uri_parse
aeron_ipv4_addr_resolver
aeron_ipv4_does_prefix_match
aeron_ipv4_netmask_to_prefixlen
aeron_ipv6_addr_resolver
aeron_ipv6_does_prefix_match
aeron_ipv6_netmask_to_prefixlen
aeron_is_addr_multicast
aeron_is_directory
aeron_is_driver_active

Determine if an aeron driver is using a given aeron directory.

aeron_is_driver_active_with_cnc
aeron_is_wildcard_addr
aeron_is_wildcard_port
aeron_linger_resource_entry_delete
aeron_linger_resource_entry_has_reached_end_of_life
aeron_linger_resource_entry_on_time_event
aeron_logbuffer_check_page_size
aeron_logbuffer_check_term_length
aeron_lookup_interfaces
aeron_lookup_interfaces_from_ifaddrs
aeron_loss_detector_init
aeron_loss_detector_nak_multicast_delay_generator
aeron_loss_detector_scan
aeron_loss_reporter_create_entry
aeron_loss_reporter_init
aeron_loss_reporter_read
aeron_main_do_work

Call the Conductor main do_work duty cycle once.

aeron_main_idle_strategy

Call the Conductor Idle Strategy.

aeron_map_existing_file
aeron_map_existing_log
aeron_map_new_file
aeron_map_raw_log
aeron_map_raw_log_close
aeron_max_multicast_flow_control_strategy_supplier
aeron_min_flow_control_strategy_supplier
aeron_mpsc_concurrent_array_queue_close
aeron_mpsc_concurrent_array_queue_init
aeron_mpsc_rb_consumer_heartbeat_time
aeron_mpsc_rb_consumer_heartbeat_time_value
aeron_mpsc_rb_init
aeron_mpsc_rb_next_correlation_id
aeron_mpsc_rb_read
aeron_mpsc_rb_unblock
aeron_mpsc_rb_write
aeron_name_resolver_init
aeron_name_resolver_resolve_host_and_port
aeron_name_resolver_supplier_load
aeron_nano_clock

Return time in nanoseconds for machine. Is not wall clock time.

aeron_nano_sleep
aeron_net_init
aeron_network_publication_check_for_blocked_publisher
aeron_network_publication_clean_buffer
aeron_network_publication_close
aeron_network_publication_create
aeron_network_publication_decref
aeron_network_publication_entry_delete
aeron_network_publication_entry_has_reached_end_of_life
aeron_network_publication_entry_on_time_event
aeron_network_publication_incref
aeron_network_publication_location
aeron_network_publication_on_nak
aeron_network_publication_on_rttm
aeron_network_publication_on_status_message
aeron_network_publication_on_time_event
aeron_network_publication_resend
aeron_network_publication_send
aeron_network_publication_send_data
aeron_network_publication_update_pub_lmt
aeron_next_correlation_id

Return a unique correlation id from the driver.

aeron_print_counters

Call stream_out to print the counter labels and values.

aeron_properties_buffer_load

Load properties from a string containing name=value pairs and set appropriate environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

aeron_properties_file_load

Load properties file and set appropriate environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

aeron_properties_http_load

Load properties from HTTP URL and set environment variables for the process so that subsequent calls to aeron_driver_context_init will use those values.

aeron_properties_load

Load properties based on URL or filename. If string contains file or http URL, it will attempt to load properties from a file or http as indicated. If not a URL, then it will try to load the string as a filename.

aeron_publication_add_destination

Add a destination manually to a multi-destination-cast publication.

aeron_publication_channel_status
aeron_publication_close

Asynchronously close the publication.

aeron_publication_image_add_connection_if_unknown
aeron_publication_image_add_destination
aeron_publication_image_clean_buffer_to
aeron_publication_image_close
aeron_publication_image_create
aeron_publication_image_entry_delete
aeron_publication_image_entry_has_reached_end_of_life
aeron_publication_image_entry_on_time_event
aeron_publication_image_initiate_rttm
aeron_publication_image_insert_packet
aeron_publication_image_location
aeron_publication_image_on_gap_detected
aeron_publication_image_on_rttm
aeron_publication_image_on_time_event
aeron_publication_image_remove_destination
aeron_publication_image_send_pending_loss
aeron_publication_image_send_pending_status_message
aeron_publication_image_track_rebuild
aeron_publication_offer

Non-blocking publish of a buffer containing a message.

aeron_publication_offerv

Non-blocking publish by gathering buffer vectors into a message.

aeron_publication_remove_destination

Remove a previously added destination manually from a multi-destination-cast publication.

aeron_publication_try_claim
aeron_randomised_int32
aeron_reallocf
aeron_receive_channel_endpoint_add_destination
aeron_receive_channel_endpoint_add_pending_setup
aeron_receive_channel_endpoint_add_pending_setup_destination
aeron_receive_channel_endpoint_add_poll_transports
aeron_receive_channel_endpoint_check_for_re_resolution
aeron_receive_channel_endpoint_close
aeron_receive_channel_endpoint_create
aeron_receive_channel_endpoint_decref_to_stream
aeron_receive_channel_endpoint_decref_to_stream_and_session
aeron_receive_channel_endpoint_delete
aeron_receive_channel_endpoint_dispatch
aeron_receive_channel_endpoint_entry_delete
aeron_receive_channel_endpoint_entry_has_reached_end_of_life
aeron_receive_channel_endpoint_entry_on_time_event
aeron_receive_channel_endpoint_incref_to_stream
aeron_receive_channel_endpoint_incref_to_stream_and_session
aeron_receive_channel_endpoint_on_add_publication_image
aeron_receive_channel_endpoint_on_add_subscription
aeron_receive_channel_endpoint_on_add_subscription_by_session
aeron_receive_channel_endpoint_on_data
aeron_receive_channel_endpoint_on_remove_publication_image
aeron_receive_channel_endpoint_on_remove_subscription
aeron_receive_channel_endpoint_on_remove_subscription_by_session
aeron_receive_channel_endpoint_on_rttm
aeron_receive_channel_endpoint_on_setup
aeron_receive_channel_endpoint_remove_destination
aeron_receive_channel_endpoint_remove_poll_transports
aeron_receive_channel_endpoint_send_nak
aeron_receive_channel_endpoint_send_rttm
aeron_receive_channel_endpoint_send_sm
aeron_receive_channel_endpoint_sendmsg
aeron_receive_channel_endpoint_update_control_address
aeron_receive_destination_create
aeron_receive_destination_delete
aeron_receiver_channel_endpoint_validate_sender_mtu_length
aeron_remove_available_counter_handler
aeron_remove_close_handler
aeron_remove_unavailable_counter_handler
aeron_res_header_entry_length
aeron_res_header_entry_length_ipv4
aeron_res_header_entry_length_ipv6
aeron_retransmit_handler_close
aeron_retransmit_handler_init
aeron_retransmit_handler_on_nak
aeron_retransmit_handler_process_timeouts
aeron_semantic_version_compose
aeron_semantic_version_major
aeron_semantic_version_minor
aeron_semantic_version_patch
aeron_send_channel_endpoint_add_publication
aeron_send_channel_endpoint_check_for_re_resolution
aeron_send_channel_endpoint_create
aeron_send_channel_endpoint_decref
aeron_send_channel_endpoint_delete
aeron_send_channel_endpoint_dispatch
aeron_send_channel_endpoint_entry_delete
aeron_send_channel_endpoint_entry_has_reached_end_of_life
aeron_send_channel_endpoint_entry_on_time_event
aeron_send_channel_endpoint_incref
aeron_send_channel_endpoint_on_nak
aeron_send_channel_endpoint_on_rttm
aeron_send_channel_endpoint_on_status_message
aeron_send_channel_endpoint_remove_publication
aeron_send_channel_endpoint_resolution_change
aeron_send_channel_sendmmsg
aeron_send_channel_sendmsg
aeron_set_err
aeron_set_err_from_last_err_code
aeron_set_getifaddrs
aeron_set_ipv4_wildcard_host_and_port
aeron_setsockopt
aeron_socket
aeron_spsc_concurrent_array_queue_close
aeron_spsc_concurrent_array_queue_init
aeron_start

Start an aeron_t. This may spawn a thread for the Client Conductor.

aeron_static_window_congestion_control_strategy_supplier
aeron_subscription_add_destination

Add a destination manually to a multi-destination subscription.

aeron_subscription_block_poll

Poll the images under the subscription for available message fragments in blocks.

aeron_subscription_channel_status
aeron_subscription_close

Asynchronously close the subscription.

aeron_subscription_controlled_poll

Poll in a controlled manner the images under the subscription for available message fragments. Control is applied to fragments in the stream. If more fragments can be read on another stream they will even if BREAK or ABORT is returned from the fragment handler.

aeron_subscription_for_each_image

Iterate over the images for this subscription calling the given function.

aeron_subscription_image_by_session_id

Return the image associated with the given session_id under the given subscription.

aeron_subscription_image_count

Count of images associated to this subscription.

aeron_subscription_is_closed
aeron_subscription_is_connected

Is this subscription connected by having at least one open publication image.

aeron_subscription_poll

Poll the images under the subscription for available message fragments.

aeron_subscription_remove_destination

Remove a previously added destination from a multi-destination subscription.

aeron_system_counters_close
aeron_system_counters_init
aeron_tagged_flow_control_strategy_supplier
aeron_tagged_flow_control_strategy_to_string
aeron_temp_filename
aeron_thread_set_name
aeron_tokenise
aeron_try_parse_ipv4
aeron_try_parse_ipv6
aeron_udp_channel_data_paths_delete
aeron_udp_channel_data_paths_init
aeron_udp_channel_delete
aeron_udp_channel_interceptor_bindings_load
aeron_udp_channel_parse
aeron_udp_channel_transport_bind_addr_and_port
aeron_udp_channel_transport_bindings_load_media
aeron_udp_channel_transport_close
aeron_udp_channel_transport_get_so_rcvbuf
aeron_udp_channel_transport_init
aeron_udp_channel_transport_recvmmsg
aeron_udp_channel_transport_sendmmsg
aeron_udp_channel_transport_sendmsg
aeron_udp_destination_tracker_check_for_re_resolution
aeron_udp_destination_tracker_close
aeron_udp_destination_tracker_init
aeron_udp_destination_tracker_manual_add_destination
aeron_udp_destination_tracker_on_status_message
aeron_udp_destination_tracker_remove_destination
aeron_udp_destination_tracker_resolution_change
aeron_udp_destination_tracker_sendmmsg
aeron_udp_destination_tracker_sendmsg
aeron_udp_port_resolver
aeron_udp_protocol_group_tag
aeron_udp_transport_poller_add
aeron_udp_transport_poller_check_receive_endpoint_re_resolutions
aeron_udp_transport_poller_check_send_endpoint_re_resolutions
aeron_udp_transport_poller_close
aeron_udp_transport_poller_init
aeron_udp_transport_poller_poll
aeron_udp_transport_poller_remove
aeron_udp_uri_parse
aeron_unicast_flow_control_strategy_supplier
aeron_unmap
aeron_uri_close
aeron_uri_find_param_value
aeron_uri_get_int64
aeron_uri_multicast_ttl
aeron_uri_parse
aeron_uri_parse_params
aeron_uri_parse_tag
aeron_uri_publication_params
aeron_uri_subscription_params
aeron_usable_fs_space
aeron_usable_fs_space_disabled
aeron_version_full

Return full version and build string.

aeron_version_major

Return major version number.

aeron_version_minor

Return minor version number.

aeron_version_patch

Return patch version number.

Type Definitions

__int8_t
__int16_t
__int32_t
__int64_t
__pthread_list_t
__socklen_t
__uint8_t
__uint16_t
__uint32_t
__uint64_t
aeron_agent_do_work_func_t
aeron_agent_on_close_func_t
aeron_agent_on_start_func_t
aeron_agent_runner_t
aeron_async_add_counter_t
aeron_async_add_exclusive_publication_t
aeron_async_add_publication_t
aeron_async_add_subscription_t
aeron_atomic_counter_t
aeron_block_handler_t

Callback for handling a block of messages being read from a log.

aeron_broadcast_descriptor_t
aeron_broadcast_record_descriptor_t
aeron_broadcast_transmitter_t
aeron_buffer_claim_t

Structure used to hold information for a try_claim function call.

aeron_channel_endpoint_status_key_layout_t
aeron_client_t
aeron_client_timeout_t
aeron_clock_cache_t

Opaque reference to a cached clock instance.

aeron_clock_func_t

Clock function used by aeron.

aeron_cnc_metadata_t
aeron_command_add_rcv_destination_t
aeron_command_base_t
aeron_command_create_publication_image_t
aeron_command_delete_destination_t
aeron_command_destination_t
aeron_command_publication_image_t
aeron_command_re_resolve_t
aeron_command_receiver_resolution_change_t
aeron_command_remove_cool_down_t
aeron_command_remove_rcv_destination_t
aeron_command_sender_resolution_change_t
aeron_command_subscription_t
aeron_congestion_control_strategy_fini_func_t
aeron_congestion_control_strategy_initial_window_length_func_t
aeron_congestion_control_strategy_on_rttm_func_t
aeron_congestion_control_strategy_on_track_rebuild_func_t
aeron_congestion_control_strategy_should_measure_rtt_func_t
aeron_congestion_control_strategy_supplier_func_t
aeron_congestion_control_strategy_t
aeron_context_t
aeron_controlled_fragment_assembler_t
aeron_controlled_fragment_handler_action_en
aeron_controlled_fragment_handler_t

Callback for handling fragments of data being read from a log.

aeron_correlated_command_t
aeron_counter_command_t
aeron_counter_link_t
aeron_counter_metadata_descriptor_t
aeron_counter_t
aeron_counter_update_t
aeron_counter_value_descriptor_t
aeron_counters_manager_t
aeron_counters_reader_foreach_counter_func_t

Function called by aeron_counters_reader_foreach_counter for each counter in the aeron_counters_reader_t.

aeron_counters_reader_foreach_metadata_func_t
aeron_counters_reader_t
aeron_data_header_t
aeron_data_packet_dispatcher_stream_interest_t
aeron_data_packet_dispatcher_t
aeron_destination_command_t
aeron_distinct_error_log_observation_list_t
aeron_distinct_error_log_t
aeron_distinct_observation_t
aeron_driver_conductor_proxy_t
aeron_driver_conductor_t
aeron_driver_conductor_to_client_interceptor_func_t
aeron_driver_conductor_to_driver_interceptor_func_t
aeron_driver_context_t
aeron_driver_managed_resource_t
aeron_driver_receiver_image_entry_t
aeron_driver_receiver_pending_setup_entry_t
aeron_driver_receiver_proxy_t
aeron_driver_receiver_t
aeron_driver_sender_network_publication_entry_t
aeron_driver_sender_proxy_t
aeron_driver_sender_t
aeron_driver_t
aeron_driver_termination_hook_func_t
aeron_driver_termination_validator_func_t
aeron_error_handler_t

The error handler to be called when an error occurs.

aeron_error_log_entry_t
aeron_error_log_reader_func_t
aeron_error_response_t
aeron_exclusive_publication_t
aeron_feedback_delay_generator_func_t
aeron_feedback_delay_generator_state_t
aeron_flow_control_strategy_fini_func_t
aeron_flow_control_strategy_has_required_receivers
aeron_flow_control_strategy_on_idle_func_t
aeron_flow_control_strategy_on_sm_func_t
aeron_flow_control_strategy_supplier_func_t
aeron_flow_control_strategy_supplier_func_table_entry_t
aeron_flow_control_strategy_t
aeron_flow_control_tagged_options_t
aeron_fragment_assembler_t
aeron_fragment_handler_t

Callback for handling fragments of data being read from a log.

aeron_frame_header_t
aeron_freeifaddrs_func_t
aeron_getifaddrs_func_t
aeron_header_t
aeron_heartbeat_timestamp_key_layout_t
aeron_idle_strategy_func_t
aeron_idle_strategy_init_func_t
aeron_idle_strategy_t
aeron_ifaddr_func_t
aeron_image_buffers_ready_t
aeron_image_controlled_fragment_assembler_t
aeron_image_fragment_assembler_t
aeron_image_message_t
aeron_image_t
aeron_int64_to_ptr_hash_map_t
aeron_int64_to_ptr_hash_map_for_each_func_t
aeron_int64_to_ptr_hash_map_predicate_func_t
aeron_int64_counter_map_t
aeron_int64_counter_map_for_each_func_t
aeron_int64_to_tagged_ptr_entry_t
aeron_int64_to_tagged_ptr_hash_map_t
aeron_int64_to_tagged_ptr_hash_map_for_each_func_t
aeron_int64_to_tagged_ptr_hash_map_predicate_func_t
aeron_iovec_t

Structure to hold pointer to a buffer and the buffer length.

aeron_ipc_channel_params_t
aeron_ipc_publication_entry_t
aeron_ipc_publication_t
aeron_linger_resource_entry_t
aeron_local_sockaddr_key_layout_t
aeron_log_buffer_t
aeron_log_func_t

Function to return logging information.

aeron_logbuffer_metadata_t
aeron_loss_detector_gap_t
aeron_loss_detector_t
aeron_loss_reporter_entry_offset_t
aeron_loss_reporter_entry_t
aeron_loss_reporter_read_entry_func_t
aeron_loss_reporter_t
aeron_map_raw_log_close_func_t
aeron_map_raw_log_func_t
aeron_mapped_buffer_t
aeron_mapped_file_t
aeron_mapped_raw_log_t
aeron_mpsc_concurrent_array_queue_t
aeron_mpsc_rb_t
aeron_mutex_t
aeron_nak_header_t
aeron_name_resolver_close_func_t
aeron_name_resolver_do_work_func_t
aeron_name_resolver_lookup_func_t

Resolves a name to a host:port string.

aeron_name_resolver_resolve_func_t
aeron_name_resolver_supplier_func_t
aeron_name_resolver_t
aeron_network_publication_entry_t
aeron_network_publication_t
aeron_on_available_counter_t
aeron_on_available_image_t

Function called by aeron_client_t to deliver notifications that an aeron_image_t was added.

aeron_on_close_client_t
aeron_on_new_publication_t

Function called by aeron_client_t to deliver notification that the media driver has added an aeron_publication_t or aeron_exclusive_publication_t successfully.

aeron_on_new_subscription_t

Function called by aeron_client_t to deliver notification that the media driver has added an aeron_subscription_t successfully.

aeron_on_unavailable_counter_t
aeron_on_unavailable_image_t

Function called by aeron_client_t to deliver notifications than an aeron_image_t has been removed from use and should not be used any longer.

aeron_operation_succeeded_t
aeron_per_thread_error_t
aeron_position_t
aeron_publication_buffers_ready_t
aeron_publication_command_t
aeron_publication_image_connection_t
aeron_publication_image_entry_t
aeron_publication_image_t
aeron_publication_link_t
aeron_publication_t
aeron_queue_drain_func_t
aeron_queue_offer_result_stct
aeron_rb_descriptor_t
aeron_rb_handler_t
aeron_rb_record_descriptor_t
aeron_rb_write_result_stct
aeron_receive_channel_endpoint_entry_t
aeron_receive_channel_endpoint_t
aeron_receive_destination_entry_t
aeron_receive_destination_t
aeron_remove_command_t
aeron_reserved_value_supplier_t

Function called when filling in the reserved value field of a message.

aeron_resolution_header_ipv4_t
aeron_resolution_header_ipv6_t
aeron_resolution_header_t
aeron_resource_linger_func_t
aeron_retransmit_action_t
aeron_retransmit_handler_resend_func_t
aeron_retransmit_handler_t
aeron_rttm_header_t
aeron_send_channel_endpoint_entry_t
aeron_send_channel_endpoint_t
aeron_setup_header_t
aeron_socket_t
aeron_spsc_concurrent_array_queue_t
aeron_status_message_header_t
aeron_status_message_optional_header_t
aeron_str_to_ptr_hash_map_for_each_func_t
aeron_str_to_ptr_hash_map_key_t
aeron_str_to_ptr_hash_map_t
aeron_stream_position_counter_key_layout_t
aeron_subscribable_list_entry_t
aeron_subscribable_t
aeron_subscription_command_t
aeron_subscription_link_t
aeron_subscription_ready_t
aeron_subscription_t
aeron_system_counter_enum_stct
aeron_system_counter_t
aeron_system_counters_t
aeron_t
aeron_term_gap_scanner_on_gap_detected_func_t
aeron_terminate_driver_command_t
aeron_tetherable_position_t
aeron_thread_t
aeron_udp_channel_data_paths_t
aeron_udp_channel_incoming_interceptor_t
aeron_udp_channel_interceptor_bindings_load_func_t
aeron_udp_channel_interceptor_bindings_t
aeron_udp_channel_interceptor_close_func_t
aeron_udp_channel_interceptor_incoming_func_t
aeron_udp_channel_interceptor_init_func_t
aeron_udp_channel_interceptor_outgoing_mmsg_func_t
aeron_udp_channel_interceptor_outgoing_msg_func_t
aeron_udp_channel_outgoing_interceptor_t
aeron_udp_channel_params_t
aeron_udp_channel_t
aeron_udp_channel_transport_affinity_en
aeron_udp_channel_transport_bind_addr_and_port_func_t
aeron_udp_channel_transport_bindings_t
aeron_udp_channel_transport_close_func_t
aeron_udp_channel_transport_entry_t
aeron_udp_channel_transport_get_so_rcvbuf_func_t
aeron_udp_channel_transport_init_func_t
aeron_udp_channel_transport_recvmmsg_func_t
aeron_udp_channel_transport_sendmmsg_func_t
aeron_udp_channel_transport_sendmsg_func_t
aeron_udp_channel_transport_t
aeron_udp_destination_entry_t
aeron_udp_destination_tracker_t
aeron_udp_transport_poller_add_func_t
aeron_udp_transport_poller_close_func_t
aeron_udp_transport_poller_init_func_t
aeron_udp_transport_poller_poll_func_t
aeron_udp_transport_poller_remove_func_t
aeron_udp_transport_poller_t
aeron_udp_transport_recv_func_t
aeron_uri_hostname_resolver_func_t
aeron_uri_param_t
aeron_uri_params_t
aeron_uri_parse_callback_t
aeron_uri_publication_params_t
aeron_uri_subscription_params_t
aeron_uri_t
aeron_usable_fs_space_func_t
in_addr_t
pthread_t
sa_family_t
size_t
socklen_t

Unions

aeron_uri_stct__bindgen_ty_1
ifaddrs__bindgen_ty_1
in6_addr__bindgen_ty_1
pthread_mutex_t