Skip to main content Module bindings Copy item path Source pub use self::aeron_controlled_fragment_handler_action_en as aeron_controlled_fragment_handler_action_t;pub use self::aeron_uri_type_enum as aeron_uri_type_t;pub use self::aeron_uri_ats_status_en as aeron_uri_ats_status_t;pub use self::aeron_cnc_load_result_stct as aeron_cnc_load_result_t;__darwin_pthread_handler_rec _opaque_pthread_attr_t _opaque_pthread_cond_t _opaque_pthread_mutex_t _opaque_pthread_t aeron_agent_runner_stct aeron_buffer_claim_stct Structure used to hold information for a try_claim function call. aeron_client_registering_resource_stct aeron_cnc_constants_stct aeron_cnc_metadata_stct aeron_cnc_stct aeron_context_stct aeron_controlled_fragment_assembler_stct aeron_counter_constants_stct Configuration for a counter that does not change during its lifetime. aeron_counter_metadata_descriptor_stct aeron_counter_stct aeron_counter_value_descriptor_stct aeron_counters_reader_buffers_stct aeron_counters_reader_stct aeron_data_header_as_longs_stct aeron_data_header_stct aeron_error_stct aeron_exclusive_publication_stct aeron_fragment_assembler_stct aeron_frame_header_stct aeron_header_stct aeron_header_values_frame_stct aeron_header_values_stct aeron_idle_strategy_stct aeron_image_constants_stct Configuration for an image that does not change during it’s lifetime. aeron_image_controlled_fragment_assembler_stct aeron_image_fragment_assembler_stct aeron_image_stct aeron_iovec_stct aeron_ipc_channel_params_stct aeron_log_buffer_stct aeron_logbuffer_metadata_stct aeron_loss_reporter_entry_stct aeron_loss_reporter_stct aeron_mapped_buffer_stct aeron_mapped_file_stct aeron_mapped_raw_log_stct aeron_nak_header_stct aeron_on_available_counter_pair_stct aeron_on_close_client_pair_stct aeron_on_unavailable_counter_pair_stct aeron_option_header_stct aeron_per_thread_error_stct aeron_publication_constants_stct Configuration for a publication that does not change during it’s lifetime. aeron_publication_error_values_stct aeron_publication_stct aeron_resolution_header_ipv4_stct aeron_resolution_header_ipv6_stct aeron_resolution_header_stct aeron_response_setup_header_stct aeron_rttm_header_stct aeron_setup_header_stct 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_subscription_constants_stct aeron_subscription_stct aeron_udp_channel_params_stct aeron_uri_param_stct aeron_uri_params_stct aeron_uri_stct aeron_uri_string_builder_stct aeron_cnc_load_result_stct aeron_controlled_fragment_handler_action_en aeron_uri_ats_status_en aeron_uri_type_enum AERON_AGENT_ON_START_FUNCTION_ENV_VAR 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_CACHE_LINE_LENGTH AERON_CLIENT_ERROR_BUFFER_FULL AERON_CLIENT_ERROR_CLIENT_TIMEOUT AERON_CLIENT_ERROR_CONDUCTOR_SERVICE_TIMEOUT AERON_CLIENT_ERROR_DRIVER_BUFFER_FULL AERON_CLIENT_ERROR_DRIVER_TIMEOUT AERON_CLIENT_IDLE_SLEEP_DURATION_ENV_VAR AERON_CLIENT_MAX_LOCAL_ADDRESS_STR_LEN AERON_CLIENT_NAME_ENV_VAR AERON_CLIENT_PRE_TOUCH_MAPPED_MEMORY_ENV_VAR AERON_CLIENT_RESOURCE_LINGER_DURATION_ENV_VAR AERON_CNC_FILE AERON_COMPILER_GCC AERON_COMPILER_LLVM AERON_COUNTER_ARCHIVE_CONTROL_SESSIONS_TYPE_ID AERON_COUNTER_ARCHIVE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_ARCHIVE_ERROR_COUNT_TYPE_ID AERON_COUNTER_ARCHIVE_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_ARCHIVE_RECORDER_MAX_WRITE_TIME_TYPE_ID AERON_COUNTER_ARCHIVE_RECORDER_TOTAL_WRITE_BYTES_TYPE_ID AERON_COUNTER_ARCHIVE_RECORDER_TOTAL_WRITE_TIME_TYPE_ID AERON_COUNTER_ARCHIVE_RECORDING_POSITION_TYPE_ID AERON_COUNTER_ARCHIVE_REPLAYER_MAX_READ_TIME_TYPE_ID AERON_COUNTER_ARCHIVE_REPLAYER_TOTAL_READ_BYTES_TYPE_ID AERON_COUNTER_ARCHIVE_REPLAYER_TOTAL_READ_TIME_TYPE_ID AERON_COUNTER_ARCHIVE_REPLAY_SESSION_COUNT_TYPE_ID AERON_COUNTER_ATS_AEAD_ERRORS_TYPE_ID AERON_COUNTER_ATS_BYTES_DECRYPTED_TYPE_ID AERON_COUNTER_ATS_BYTES_ENCRYPTED_TYPE_ID AERON_COUNTER_ATS_DISCARDS_NON_ATS_TYPE_ID AERON_COUNTER_ATS_DROPPED_SM_TYPE_ID AERON_COUNTER_ATS_EC_KEY_SIG_ERRORS_TYPE_ID AERON_COUNTER_ATS_RSA_KEY_UNKNOWN_TYPE_ID AERON_COUNTER_ATS_TRANSPORTS_TYPE_ID AERON_COUNTER_ATS_UNICAST_RE_KEYINGS_TYPE_ID AERON_COUNTER_ATS_UNICAST_RE_KEYING_RSA_KEY_MISMATCH_TYPE_ID AERON_COUNTER_CACHE_LINE_LENGTH AERON_COUNTER_CHANNEL_MDC_NUM_DESTINATIONS_NAME AERON_COUNTER_CHANNEL_NUM_DESTINATIONS_TYPE_ID AERON_COUNTER_CLIENT_HEARTBEAT_TIMESTAMP_NAME AERON_COUNTER_CLIENT_HEARTBEAT_TIMESTAMP_TYPE_ID AERON_COUNTER_CLUSTERED_SERVICE_SNAPSHOT_DURATION_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_BACKUP_ERROR_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_BACKUP_LIVE_LOG_POSITION_TYPE_ID AERON_COUNTER_CLUSTER_BACKUP_QUERY_DEADLINE_TYPE_ID AERON_COUNTER_CLUSTER_BACKUP_STATE_TYPE_ID AERON_COUNTER_CLUSTER_CLIENT_TIMEOUT_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_CLUSTERED_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_CLUSTERED_SERVICE_ERROR_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_CLUSTERED_SERVICE_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_CLUSTER_COMMIT_POSITION_TYPE_ID AERON_COUNTER_CLUSTER_CONSENSUS_MODULE_ERROR_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_CONSENSUS_MODULE_STATE_TYPE_ID AERON_COUNTER_CLUSTER_CONTROL_TOGGLE_TYPE_ID AERON_COUNTER_CLUSTER_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_ELECTION_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_ELECTION_STATE_TYPE_ID AERON_COUNTER_CLUSTER_INVALID_REQUEST_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_LEADERSHIP_TERM_ID_TYPE_ID AERON_COUNTER_CLUSTER_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_CLUSTER_NODE_ROLE_TYPE_ID AERON_COUNTER_CLUSTER_RECOVERY_STATE_TYPE_ID AERON_COUNTER_CLUSTER_SNAPSHOT_COUNTER_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_CONTROL_TOGGLE_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_ERROR_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_HEARTBEAT_RESPONSE_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_SOURCE_MEMBER_ID_TYPE_ID AERON_COUNTER_CLUSTER_STANDBY_STATE_TYPE_ID AERON_COUNTER_CLUSTER_TOTAL_SNAPSHOT_DURATION_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_TRANSITION_MODULE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_CLUSTER_TRANSITION_MODULE_ERROR_COUNT_TYPE_ID AERON_COUNTER_CLUSTER_TRANSITION_MODULE_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_CLUSTER_TRANSITION_MODULE_STATE_TYPE_ID AERON_COUNTER_DPDK_ARP_MISS_TYPE_ID AERON_COUNTER_DPDK_BYTES_TYPE_ID AERON_COUNTER_DPDK_CHECKSUM_FAILURE_TYPE_ID AERON_COUNTER_DPDK_ERROR_TYPE_ID AERON_COUNTER_DPDK_EXTENDED_STATS_TYPE_ID AERON_COUNTER_DPDK_FRAGMENTED_PACKETS_TYPE_ID AERON_COUNTER_DPDK_MEMPOOL_AVAILABLE_TYPE_ID AERON_COUNTER_DPDK_MISSED_PACKETS_TYPE_ID AERON_COUNTER_DPDK_NOBUFS_TYPE_ID AERON_COUNTER_DPDK_PKTS_TYPE_ID AERON_COUNTER_DPDK_POLLER_TYPE_ID AERON_COUNTER_DPDK_PORT_INFO_TYPE_ID AERON_COUNTER_DPDK_QUEUE_DROP_COUNT_TYPE_ID AERON_COUNTER_DPDK_RX_RECEIVER_DISCARD_TYPE_ID AERON_COUNTER_DPDK_RX_SENDER_DISCARD_TYPE_ID AERON_COUNTER_DPDK_RX_UNSUPPORTED_ETHERNET_TYPE_TYPE_ID AERON_COUNTER_DPDK_RX_UNSUPPORTED_PROTOCOL_TYPE_ID AERON_COUNTER_DPDK_TRANSPORT_TYPE_ID AERON_COUNTER_DPDK_TX_EAGAIN_TYPE_ID AERON_COUNTER_EF_VI_PORT_INFO_TYPE_ID AERON_COUNTER_EF_VI_RX_BYTES_TYPE_ID AERON_COUNTER_EF_VI_RX_DISCARD_TYPE_ID AERON_COUNTER_EF_VI_RX_INVALID_TYPE_ID AERON_COUNTER_EF_VI_RX_PKTS_TYPE_ID AERON_COUNTER_EF_VI_TRANSPORT_TYPE_ID AERON_COUNTER_EF_VI_TX_BYTES_TYPE_ID AERON_COUNTER_EF_VI_TX_EAGAIN_TYPE_ID AERON_COUNTER_EF_VI_TX_ERROR_TYPE_ID AERON_COUNTER_EF_VI_TX_NOBUFS_TYPE_ID AERON_COUNTER_EF_VI_TX_PKTS_TYPE_ID AERON_COUNTER_FC_NUM_RECEIVERS_TYPE_ID AERON_COUNTER_LOCAL_SOCKADDR_TYPE_ID AERON_COUNTER_MAX_CLIENT_NAME_LENGTH AERON_COUNTER_NAME_RESOLVER_BOOTSTRAP_NEIGHBOR_COUNTER_TYPE_ID AERON_COUNTER_NAME_RESOLVER_CACHE_ENTRIES_COUNTER_TYPE_ID AERON_COUNTER_NAME_RESOLVER_NEIGHBORS_COUNTER_TYPE_ID AERON_COUNTER_NOT_FREE_TO_REUSE AERON_COUNTER_PER_IMAGE_TYPE_ID AERON_COUNTER_PUBLISHER_LIMIT_NAME AERON_COUNTER_PUBLISHER_LIMIT_TYPE_ID AERON_COUNTER_PUBLISHER_POSITION_NAME_CONCURRENT AERON_COUNTER_PUBLISHER_POSITION_NAME_EXCLUSIVE 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_NAKS_SENT_NAME AERON_COUNTER_RECEIVER_NAKS_SENT_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_SELECTOR_CLIENTS_COUNTER_TYPE_ID AERON_COUNTER_SELECTOR_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_SELECTOR_MAX_CYCLE_TIME_TYPE_ID AERON_COUNTER_SELECTOR_SUBSCRIPTIONS_COUNTER_TYPE_ID 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_NAKS_RECEIVED_NAME AERON_COUNTER_SENDER_NAKS_RECEIVED_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_SEQUENCER_APPLICATION_ERROR_COUNT_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_INTERVAL_MAX_SERVICE_TIME_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_INTERVAL_SERVICE_TIME_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_INTERVAL_TOTAL_INVOCATIONS_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_MAX_SERVICE_TIME_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_SEQUENCE_INDEX_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_SERVICE_TIME_THRESHOLD_EXCEEDED_COUNT_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_SESSION_ID_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_SNAPSHOT_LOAD_TIME_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_SNAPSHOT_STORE_TIME_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_STATE_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_TAKE_SNAPSHOT_COUNT_TYPE_ID AERON_COUNTER_SEQUENCER_APPLICATION_TAKE_SNAPSHOT_FAILURES_TYPE_ID AERON_COUNTER_SEQUENCER_CLIENT_SNAPSHOT_ID_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_GROUP_HWM_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_INDEX_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_INITIAL_SEQUENCE_INDEX_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_INITIAL_SEQUENCE_LOG_POSITION_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_MAX_SEQUENCE_INDEX_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_MAX_SEQUENCE_LOG_POSITION_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_MIN_SEQUENCE_INDEX_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_INDEX_MIN_SEQUENCE_LOG_POSITION_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_SEQUENCER_REPLAY_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_SESSION_GREATEST_MESSAGE_ID_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_SESSION_GREATEST_MESSAGE_TIMESTAMP_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_SESSION_MESSAGES_COUNTER_TYPE_ID AERON_COUNTER_SEQUENCER_SNAPSHOT_SERVICE_CYCLE_TIME_THRESHOLD_EXCEEDED_TYPE_ID AERON_COUNTER_SEQUENCER_SNAPSHOT_SERVICE_MAX_CYCLE_TIME_COUNTER_TYPE_ID AERON_COUNTER_SND_LOCAL_SOCKADDR_NAME AERON_COUNTER_SUBSCRIPTION_POSITION_NAME AERON_COUNTER_SUBSCRIPTION_POSITION_TYPE_ID AERON_COUNTER_SYSTEM_COUNTER_TYPE_ID AERON_COUNTER_VMA_RX_DATA_COPY_BYTES_TYPE_ID AERON_COUNTER_VMA_RX_ZERO_COPY_BYTES_TYPE_ID AERON_COUNTER_VMA_TRANSPORTS_TYPE_ID AERON_CPU_ARM AERON_DIR_ENV_VAR AERON_DRIVER_TIMEOUT_ENV_VAR AERON_ERROR_HAS_GROUP_TAG_FLAG AERON_ERROR_MAX_TEXT_LENGTH AERON_ERROR_MAX_TOTAL_LENGTH AERON_FILEUTIL_ERROR_ENOSPC AERON_FORMAT_DATE_MAX_LENGTH AERON_FORMAT_NUMBER_TO_LOCALE_STR_LEN AERON_FRAME_HEADER_VERSION AERON_FRAME_MAX_MESSAGE_LENGTH 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_IPC_CHANNEL 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_LOSS_REPORTER_ENTRY_ALIGNMENT AERON_LOSS_REPORT_FILE AERON_MAP_DEFAULT_LOAD_FACTOR AERON_MAX_PATH AERON_MAX_UDP_PAYLOAD_LENGTH AERON_NULL_COUNTER_ID AERON_NULL_VALUE AERON_OPT_HDR_ALIGNMENT AERON_PERSISTENT_SUBSCRIPTION_JOIN_DIFFERENCE_TYPE_ID AERON_PERSISTENT_SUBSCRIPTION_LIVE_JOINED_COUNT_TYPE_ID AERON_PERSISTENT_SUBSCRIPTION_LIVE_LEFT_COUNT_TYPE_ID AERON_PERSISTENT_SUBSCRIPTION_STATE_TYPE_ID AERON_PUBLICATIONS_DIR AERON_PUBLICATION_ADMIN_ACTION AERON_PUBLICATION_BACK_PRESSURED AERON_PUBLICATION_CLOSED AERON_PUBLICATION_ERROR AERON_PUBLICATION_MAX_POSITION_EXCEEDED AERON_PUBLICATION_NOT_CONNECTED AERON_RESPONSE_ADDRESS_TYPE_IPV4 AERON_RESPONSE_ADDRESS_TYPE_IPV6 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_SPY_PREFIX AERON_SYSTEM_COUNTER_ID_AERON_VERSION AERON_SYSTEM_COUNTER_ID_BYTES_CURRENTLY_MAPPED AERON_SYSTEM_COUNTER_ID_BYTES_RECEIVED AERON_SYSTEM_COUNTER_ID_BYTES_SENT AERON_SYSTEM_COUNTER_ID_CLIENT_TIMEOUTS AERON_SYSTEM_COUNTER_ID_CONDUCTOR_CYCLE_TIME_THRESHOLD_EXCEEDED AERON_SYSTEM_COUNTER_ID_CONDUCTOR_MAX_CYCLE_TIME AERON_SYSTEM_COUNTER_ID_CONDUCTOR_PROXY_FAILS AERON_SYSTEM_COUNTER_ID_CONTROLLABLE_IDLE_STRATEGY AERON_SYSTEM_COUNTER_ID_CONTROL_PROTOCOL_VERSION AERON_SYSTEM_COUNTER_ID_ERRORS AERON_SYSTEM_COUNTER_ID_ERROR_FRAMES_RECEIVED AERON_SYSTEM_COUNTER_ID_ERROR_FRAMES_SENT AERON_SYSTEM_COUNTER_ID_FLOW_CONTROL_OVER_RUNS AERON_SYSTEM_COUNTER_ID_FLOW_CONTROL_UNDER_RUNS AERON_SYSTEM_COUNTER_ID_FREE_FAILS AERON_SYSTEM_COUNTER_ID_HEARTBEATS_RECEIVED AERON_SYSTEM_COUNTER_ID_HEARTBEATS_SENT AERON_SYSTEM_COUNTER_ID_IMAGES_REJECTED AERON_SYSTEM_COUNTER_ID_INVALID_PACKETS AERON_SYSTEM_COUNTER_ID_LOSS_GAP_FILLS AERON_SYSTEM_COUNTER_ID_NAK_MESSAGES_RECEIVED AERON_SYSTEM_COUNTER_ID_NAK_MESSAGES_SENT AERON_SYSTEM_COUNTER_ID_NAME_RESOLVER_MAX_TIME AERON_SYSTEM_COUNTER_ID_NAME_RESOLVER_TIME_THRESHOLD_EXCEEDED AERON_SYSTEM_COUNTER_ID_NATIVE_RESOURCE_AGENT_PROXY_FAILS AERON_SYSTEM_COUNTER_ID_POSSIBLE_TTL_ASYMMETRY AERON_SYSTEM_COUNTER_ID_PUBLICATIONS_REVOKED AERON_SYSTEM_COUNTER_ID_PUBLICATION_IMAGES_REVOKED AERON_SYSTEM_COUNTER_ID_RECEIVER_CYCLE_TIME_THRESHOLD_EXCEEDED AERON_SYSTEM_COUNTER_ID_RECEIVER_MAX_CYCLE_TIME AERON_SYSTEM_COUNTER_ID_RECEIVER_PROXY_FAILS AERON_SYSTEM_COUNTER_ID_RESOLUTION_CHANGES AERON_SYSTEM_COUNTER_ID_RETRANSMITS_SENT AERON_SYSTEM_COUNTER_ID_RETRANSMITTED_BYTES AERON_SYSTEM_COUNTER_ID_RETRANSMIT_OVERFLOW AERON_SYSTEM_COUNTER_ID_SENDER_CYCLE_TIME_THRESHOLD_EXCEEDED AERON_SYSTEM_COUNTER_ID_SENDER_FLOW_CONTROL_LIMITS AERON_SYSTEM_COUNTER_ID_SENDER_MAX_CYCLE_TIME AERON_SYSTEM_COUNTER_ID_SENDER_PROXY_FAILS AERON_SYSTEM_COUNTER_ID_SHORT_SENDS AERON_SYSTEM_COUNTER_ID_STATUS_MESSAGES_RECEIVED AERON_SYSTEM_COUNTER_ID_STATUS_MESSAGES_REJECTED AERON_SYSTEM_COUNTER_ID_STATUS_MESSAGES_SENT AERON_SYSTEM_COUNTER_ID_UNBLOCKED_COMMANDS AERON_SYSTEM_COUNTER_ID_UNBLOCKED_PUBLICATIONS 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_CONTROL_MODE_RESPONSE_VALUE AERON_UDP_CHANNEL_ENDPOINT_KEY AERON_UDP_CHANNEL_INTERFACE_KEY AERON_UDP_CHANNEL_RELIABLE_KEY AERON_UDP_CHANNEL_TTL_KEY AERON_URI_ALIAS_KEY AERON_URI_ATS_KEY AERON_URI_CC_KEY AERON_URI_CHANNEL_RCV_TIMESTAMP_OFFSET_KEY AERON_URI_CHANNEL_SND_TIMESTAMP_OFFSET_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_MAX_LENGTH AERON_URI_MAX_RESEND_KEY AERON_URI_MEDIA_RCV_TIMESTAMP_OFFSET_KEY AERON_URI_MTU_LENGTH_KEY AERON_URI_NAK_DELAY_KEY AERON_URI_PUBLICATION_WINDOW_KEY AERON_URI_RECEIVER_WINDOW_KEY AERON_URI_REJOIN_KEY AERON_URI_RESPONSE_CORRELATION_ID_KEY AERON_URI_RESPONSE_CORRELATION_ID_PROTOTYPE AERON_URI_SESSION_ID_KEY AERON_URI_SOCKET_RCVBUF_KEY AERON_URI_SOCKET_SNDBUF_KEY AERON_URI_SPARSE_TERM_KEY AERON_URI_SPIES_SIMULATE_CONNECTION_KEY AERON_URI_STREAM_ID_KEY AERON_URI_STRING_BUILDER_MEDIA_KEY AERON_URI_STRING_BUILDER_PREFIX_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_URI_TIMESTAMP_OFFSET_RESERVED AERON_URI_UNTETHERED_LINGER_TIMEOUT_KEY AERON_URI_UNTETHERED_RESTING_TIMEOUT_KEY AERON_URI_UNTETHERED_WINDOW_LIMIT_TIMEOUT_KEY aeron_add_available_counter_handler ⚠ Add a handler to be called when a new counter becomes available. aeron_add_close_handler ⚠ Add a handler to be called when client is closed. aeron_add_unavailable_counter_handler ⚠ Add a handler to be called when a new counter becomes unavailable or goes away. aeron_agent_close ⚠ aeron_agent_init ⚠ aeron_agent_on_start_load ⚠ aeron_agent_start ⚠ aeron_agent_stop ⚠ aeron_alloc ⚠ aeron_alloc_aligned ⚠ 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_cancel ⚠ Cancel an in-progress aeron_async_add_counter operation. Not applicable to
aeron_async_add_static_counter, i.e. attempt to cancel static counter will fail with an error. aeron_async_add_counter_get_registration_id ⚠ Gets the registration id for addition of the counter. Note that using this after a call to poll the succeeds or
errors is undefined behaviour. As the async_add_counter_t may have been freed. aeron_async_add_counter_poll ⚠ Poll the completion of the aeron_async_add_counter or aeron_async_add_static_counter calls. 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_cancel ⚠ Cancel an in-progress aeron_async_add_exclusive_publication operation. aeron_async_add_exclusive_publication_get_registration_id ⚠ Gets the registration id for addition of the exclusive_publication. Note that using this after a call to poll the
succeeds or errors is undefined behaviour. As the async_add_exclusive_publication_t may have been freed. 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_cancel ⚠ Cancel an in-progress aeron_async_add_publication operation. aeron_async_add_publication_get_registration_id ⚠ Gets the registration id for addition of the publication. Note that using this after a call to poll the succeeds or
errors is undefined behaviour. As the async_add_publication_t may have been freed. aeron_async_add_publication_poll ⚠ Poll the completion of the aeron_async_add_publication call. aeron_async_add_static_counter ⚠ Asynchronously allocates or returns an existing static counter instance using specified type_id and
registration_id. Such counter cannot be deleted and its lifecycle is decoupled from the client that created it.
Returns an object to use to determine when the counter is available. 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_cancel ⚠ Cancel an in-progress aeron_async_add_subscription operation. aeron_async_add_subscription_get_registration_id ⚠ Gets the registration id for addition of the subscription. Note that using this after a call to poll the succeeds or
errors is undefined behaviour. As the async_add_subscription_t may have been freed. aeron_async_add_subscription_poll ⚠ Poll the completion of the aeron_async_add_subscription call. aeron_async_destination_get_registration_id ⚠ Gets the registration_id for the destination command supplied. Note that this is the correlation_id used for
the specified destination command, not the registration_id for the original parent resource (publication,
subscription). aeron_async_next_session_id ⚠ Asynchronously request next available session from the media driver. The session id will be unique for the
connected media driver and given {@code stream_id}. aeron_async_next_session_id_poll ⚠ Poll the completion of the aeron_async_next_session_id call. aeron_async_remove_counter ⚠ Asynchronously remove a counter. Not applicable to static counters.
If there is an aeron_counter_t object for that counter, it will get closed and freed. aeron_async_remove_exclusive_publication ⚠ Asynchronously remove an exclusive publication.
If there is an aeron_exclusive_publication_t object for that publication, it will get closed and freed. aeron_async_remove_publication ⚠ Asynchronously remove a publication.
If there is an aeron_publication_t object for that publication, it will get closed and freed. aeron_async_remove_subscription ⚠ Asynchronously remove a subscription.
If there is an aeron_subscription_t object for that subscription, it will get closed and freed. 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_id ⚠ Return the client id in use by the client. aeron_close ⚠ Close and delete aeron_t struct. aeron_cnc_close ⚠ Closes the instance of the aeron cnc and frees its resources. aeron_cnc_constants ⚠ Fetch the sets of constant values associated with this command and control file. aeron_cnc_counters_reader ⚠ Gets a counters reader for this command and control file. This does not need to be closed manually, resources
are tied to the instance of aeron_cnc. aeron_cnc_error_log_read ⚠ Reads the current error log for this driver. aeron_cnc_filename ⚠ Get the current file name of the cnc file. aeron_cnc_init ⚠ Initialise an aeron_cnc, which gives user level access to the command and control file used to communicate
with the media driver. Will wait until the media driver has loaded and the cnc file is created, up to timeout_ms.
Use a value of 0 for a non-blocking initialisation. aeron_cnc_loss_reporter_read ⚠ Read all of the data loss observations from the report in the same media driver instances as the cnc file. aeron_cnc_map_file_and_load_metadata ⚠ aeron_cnc_resolve_filename ⚠ aeron_cnc_to_driver_heartbeat ⚠ Gets the timestamp of the last heartbeat sent to the media driver from any client. aeron_cnc_version_volatile ⚠ 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_client_name ⚠ aeron_context_get_dir ⚠ aeron_context_get_driver_timeout_ms ⚠ aeron_context_get_error_handler ⚠ aeron_context_get_error_handler_clientd ⚠ aeron_context_get_idle_sleep_duration_ns ⚠ aeron_context_get_idle_strategy ⚠ aeron_context_get_idle_strategy_init_args ⚠ aeron_context_get_keepalive_interval_ns ⚠ aeron_context_get_on_available_counter ⚠ aeron_context_get_on_available_counter_clientd ⚠ aeron_context_get_on_close_client ⚠ aeron_context_get_on_close_client_clientd ⚠ 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_on_unavailable_counter ⚠ aeron_context_get_on_unavailable_counter_clientd ⚠ aeron_context_get_pre_touch_mapped_memory ⚠ aeron_context_get_publication_error_frame_handler ⚠ aeron_context_get_publication_error_frame_handler_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_request_driver_termination ⚠ Request the media driver terminates operation and closes all resources. aeron_context_set_agent_on_start_function ⚠ aeron_context_set_client_name ⚠ aeron_context_set_dir ⚠ aeron_context_set_driver_timeout_ms ⚠ aeron_context_set_error_handler ⚠ aeron_context_set_idle_sleep_duration_ns ⚠ aeron_context_set_idle_strategy ⚠ aeron_context_set_idle_strategy_init_args ⚠ aeron_context_set_keepalive_interval_ns ⚠ aeron_context_set_on_available_counter ⚠ aeron_context_set_on_close_client ⚠ aeron_context_set_on_new_exclusive_publication ⚠ aeron_context_set_on_new_publication ⚠ aeron_context_set_on_new_subscription ⚠ aeron_context_set_on_unavailable_counter ⚠ aeron_context_set_pre_touch_mapped_memory ⚠ aeron_context_set_publication_error_frame_handler ⚠ 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_counter_addr ⚠ Return a pointer to the counter value. aeron_counter_close ⚠ Asynchronously close the counter. aeron_counter_constants ⚠ Fill in a structure with the constants in use by a counter. aeron_counter_is_closed ⚠ Check if the counter is closed
@param counter to check
@return true if closed, false otherwise. aeron_counters_reader ⚠ Return a reference to the counters reader of the given client. aeron_counters_reader_addr ⚠ Get the address for a counter. aeron_counters_reader_counter_label ⚠ Get the label for a counter. aeron_counters_reader_counter_owner_id ⚠ Get the owner id assigned to a counter which will typically be the client id. aeron_counters_reader_counter_reference_id ⚠ Get the reference id assigned to a counter which will typically be the registration id of an associated Image,
Subscription, Publication, etc. aeron_counters_reader_counter_registration_id ⚠ Get the registration id assigned to a counter. aeron_counters_reader_counter_state ⚠ Get the state for a counter. aeron_counters_reader_counter_type_id ⚠ Get the type id for a counter. aeron_counters_reader_find_by_type_id_and_registration_id ⚠ Iterate over allocated counters and find the first matching a given type id and registration id. aeron_counters_reader_foreach_counter ⚠ Iterate over the counters in the counters_reader and call the given function for each counter. aeron_counters_reader_free_for_reuse_deadline_ms ⚠ Get the free for reuse deadline (ms) for a counter. aeron_counters_reader_get_buffers ⚠ Get buffer pointers and lengths for the counters reader. aeron_counters_reader_max_counter_id ⚠ Get the current max counter id. aeron_counters_reader_metadata_key ⚠ Get a pointer to the key of a counter’s metadata aeron_default_path ⚠ Get the default path used by the Aeron media driver. aeron_delete_directory ⚠ aeron_delete_file ⚠ aeron_digit_count ⚠ aeron_epoch_clock ⚠ Return time in milliseconds since epoch. Is wall clock time. aeron_err_append ⚠ aeron_err_clear ⚠ aeron_err_set ⚠ 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_exclusive_publication_append_padding ⚠ Append a padding record log of a given length to make up the log to a position. aeron_exclusive_publication_async_add_destination ⚠ Add a destination manually to a multi-destination-cast exclusive publication. aeron_exclusive_publication_async_destination_poll ⚠ Poll the completion of the add/remove of a destination to/from an exclusive publication. aeron_exclusive_publication_async_remove_destination ⚠ Remove a destination manually from a multi-destination-cast exclusive publication. aeron_exclusive_publication_async_remove_destination_by_id ⚠ Remove a destination manually from a multi-destination-cast publication. aeron_exclusive_publication_channel_status ⚠ Get the status of the media channel for this publication. aeron_exclusive_publication_close ⚠ Asynchronously close the publication. aeron_exclusive_publication_constants ⚠ Fill in a structure with the constants in use by a publication. aeron_exclusive_publication_is_closed ⚠ Has the exclusive publication closed? aeron_exclusive_publication_is_connected ⚠ Has the exclusive publication seen an active Subscriber recently? aeron_exclusive_publication_local_sockaddrs ⚠ Get all of the local socket addresses for this exclusive publication. Typically only one representing the control
address. 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_position ⚠ Get the current position to which the publication has advanced for this stream. aeron_exclusive_publication_position_limit ⚠ Get the position limit beyond which this publication will be back pressured. aeron_exclusive_publication_revoke ⚠ Asynchronously revoke and close the publication. Will callback on the on_complete notification when the publicaiton is closed.
The callback is optional, use NULL for the on_complete callback if not required. aeron_exclusive_publication_revoke_on_close ⚠ Revoke this publication when it’s closed. aeron_exclusive_publication_try_claim ⚠ Try to claim a range in the publication log into which a message can be written with zero copy semantics.
Once the message has been written then aeron_buffer_claim_commit should be called thus making it available.
A claim length cannot be greater than max payload length. aeron_file_exists ⚠ aeron_file_length ⚠ aeron_file_resolve ⚠ aeron_format_date ⚠ aeron_format_number_to_locale ⚠ aeron_format_to_hex ⚠ aeron_fprintf ⚠ Global file writing method, allows for interposition 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_ftell ⚠ aeron_get_fprintf_handler ⚠ return the fprintf_handler aeron_header_context ⚠ Get a pointer to the context associated with this message. Only valid during poll handling. Is normally a
pointer to an Image instance. aeron_header_next_term_offset ⚠ Calculates the offset of the frame immediately after this one. aeron_header_position ⚠ Get the current position to which the Image has advanced on reading this message. aeron_header_position_bits_to_shift ⚠ Get the number of times to left shift the term count to multiply by term length. aeron_header_values ⚠ Get all of the field values from the header. This will do a memcpy into the supplied header_values_t pointer. 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_active_transport_count ⚠ Count of observed active transports within the image liveness timeout. 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_constants ⚠ Fill in a structure with the constants in use by a image. 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_fragment_assembler_handler ⚠ Handler function to be passed for handling fragment assembly. 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_end_of_stream_position ⚠ The position the stream reached when EOS was received from the publisher. The position will be
INT64_MAX until the stream ends and EOS is set. 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_is_end_of_stream ⚠ Is the current consumed position at the end of the stream? aeron_image_is_publication_revoked ⚠ Was the associated publication revoked? 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_reject ⚠ aeron_image_release ⚠ Release an image that was retained by aeron_subscription_image_by_session_id or
aeron_subscription_image_at_index. 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_ipc_publication_location ⚠ aeron_is_closed ⚠ Determines if the client has been closed, e.g. via a driver timeout. Don’t call this method after calling
aeron_close as that will have already freed the associated memory. aeron_is_directory ⚠ aeron_is_driver_active ⚠ Determine if an aeron driver is using a given aeron directory. aeron_local_sockaddr_find_addrs ⚠ aeron_logbuffer_check_page_size ⚠ aeron_logbuffer_check_term_length ⚠ aeron_loss_reporter_create_entry ⚠ aeron_loss_reporter_init ⚠ aeron_loss_reporter_read ⚠ aeron_loss_reporter_record_observation ⚠ aeron_loss_reporter_resolve_filename ⚠ 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_new_file ⚠ aeron_micro_sleep ⚠ aeron_mkdir_recursive ⚠ aeron_msync ⚠ aeron_mutex_destroy ⚠ aeron_mutex_init ⚠ aeron_mutex_lock ⚠ aeron_mutex_unlock ⚠ aeron_nano_clock ⚠ Return time in nanoseconds for machine. Is not wall clock time. aeron_nano_sleep ⚠ aeron_network_publication_location ⚠ aeron_next_correlation_id ⚠ Return a unique correlation id from the driver. aeron_open_file_append ⚠ Opens or creates a new file in append mode. Will use 0644 permissions on Linux/Mac and default on Windows. 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_async_add_destination ⚠ Add a destination manually to a multi-destination-cast publication. aeron_publication_async_destination_poll ⚠ Poll the completion of the add/remove of a destination to/from a publication. aeron_publication_async_remove_destination ⚠ Remove a destination manually from a multi-destination-cast publication. aeron_publication_async_remove_destination_by_id ⚠ Remove a destination manually from a multi-destination-cast publication. aeron_publication_channel ⚠ Get the publication’s channel aeron_publication_channel_status ⚠ Get the status of the media channel for this publication. aeron_publication_close ⚠ Asynchronously close the publication. Will callback on the on_complete notification when the publication is closed.
The callback is optional, use NULL for the on_complete callback if not required. aeron_publication_constants ⚠ Fill in a structure with the constants in use by a publication. aeron_publication_error_values_copy ⚠ Copy an existing aeron_publication_error_values_t to the supplied pointer. The caller is responsible for freeing the
allocated memory using aeron_publication_error_values_delete when the copy is not longer required. aeron_publication_error_values_delete ⚠ Delete a instance of aeron_publication_error_values_t that was created when making a copy
(aeron_publication_error_values_copy). This should not be use on the pointer received via the aeron_frame_handler_t.
@param to_delete to be deleted. aeron_publication_image_location ⚠ aeron_publication_is_closed ⚠ Has the publication closed? aeron_publication_is_connected ⚠ Has the publication seen an active Subscriber recently? aeron_publication_local_sockaddrs ⚠ Get all of the local socket addresses for this publication. Typically only one representing the control address. 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_position ⚠ Get the current position to which the publication has advanced for this stream. aeron_publication_position_limit ⚠ Get the position limit beyond which this publication will be back pressured. aeron_publication_session_id ⚠ Get the publication’s session id
@param publication this
@return session id aeron_publication_stream_id ⚠ Get the publication’s stream id aeron_publication_try_claim ⚠ Try to claim a range in the publication log into which a message can be written with zero copy semantics.
Once the message has been written then aeron_buffer_claim_commit should be called thus making it available.
A claim length cannot be greater than max payload length. aeron_randomised_int32 ⚠ aeron_raw_log_free ⚠ aeron_raw_log_map ⚠ aeron_raw_log_map_existing ⚠ aeron_reallocf ⚠ aeron_realpath ⚠ aeron_remove_available_counter_handler ⚠ Remove a previously added handler to be called when a new counter becomes available. aeron_remove_close_handler ⚠ Remove a previously added handler to be called when client is closed. aeron_remove_unavailable_counter_handler ⚠ Remove a previously added handler to be called when a new counter becomes unavailable or goes away. aeron_res_header_entry_length ⚠ aeron_res_header_entry_length_ipv4 ⚠ aeron_res_header_entry_length_ipv6 ⚠ aeron_semantic_version_compose ⚠ aeron_semantic_version_major ⚠ aeron_semantic_version_minor ⚠ aeron_semantic_version_patch ⚠ aeron_set_errno ⚠ aeron_set_fprintf_handler ⚠ update the fprintf_handler, return previously installed handler aeron_start ⚠ Start an aeron_t. This may spawn a thread for the Client Conductor. aeron_subscription_async_add_destination ⚠ Add a destination manually to a multi-destination-subscription. aeron_subscription_async_destination_poll ⚠ Poll the completion of add/remove of a destination to/from a subscription. aeron_subscription_async_remove_destination ⚠ Remove a destination manually from a multi-destination-subscription. aeron_subscription_block_poll ⚠ Poll the images under the subscription for available message fragments in blocks. aeron_subscription_channel_status ⚠ Get the status of the media channel for this subscription. aeron_subscription_close ⚠ Asynchronously close the subscription. Will callback on the on_complete notification when the subscription is
closed. The callback is optional, use NULL for the on_complete callback if not required. aeron_subscription_constants ⚠ Fill in a structure with the constants in use by a 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_at_index ⚠ Return the image at the given index. 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_image_release ⚠ Release the given image and relinquish desire to use the image directly. aeron_subscription_image_retain ⚠ Retain the given image for access in the application. aeron_subscription_is_closed ⚠ Is the subscription closed. aeron_subscription_is_connected ⚠ Is this subscription connected by having at least one open publication image. aeron_subscription_local_sockaddrs ⚠ Get all of the local socket addresses for this subscription. Multiple addresses can occur if this is a
multi-destination subscription. Addresses will a string representation in numeric form. IPv6 addresses will be
surrounded by ‘[’ and ‘]’ so that the ‘:’ that separate the parts are distinguishable from the port delimiter.
E.g. [fe80::7552:c06e:6bf4:4160]:12345. As of writing the maximum length for a formatted address is 54 bytes
including the NULL terminator. AERON_CLIENT_MAX_LOCAL_ADDRESS_STR_LEN is defined to provide enough space to fit the
returned string. Returned strings will be NULL terminated. If the buffer to hold the address can not hold enough
of the message it will be truncated and the last character will be null. aeron_subscription_poll ⚠ Poll the images under the subscription for available message fragments. aeron_subscription_resolved_endpoint ⚠ Retrieves the first local socket address for this subscription. If this is not MDS then it will be the one
representing endpoint for this subscription. aeron_subscription_try_resolve_channel_endpoint_port ⚠ Retrieves the channel URI for this subscription with any wildcard ports filled in. If the channel is not UDP or
does not have a wildcard port (0), then it will return the original URI. aeron_temp_dir ⚠ Returns a new temporary directory, allocates the string which needs to be freed by the user. aeron_temp_filename ⚠ aeron_thread_get_name ⚠ aeron_thread_set_affinity ⚠ aeron_thread_set_name ⚠ aeron_tmpdir ⚠ aeron_tokenise ⚠ aeron_udp_protocol_group_tag ⚠ aeron_unmap ⚠ aeron_uri_close ⚠ aeron_uri_find_param_value ⚠ aeron_uri_get_ats ⚠ aeron_uri_get_bool ⚠ aeron_uri_get_int32 ⚠ aeron_uri_get_int64 ⚠ aeron_uri_get_receiver_window_length ⚠ aeron_uri_get_socket_buf_lengths ⚠ aeron_uri_get_timeout ⚠ aeron_uri_multicast_ttl ⚠ aeron_uri_parse ⚠ aeron_uri_parse_params ⚠ aeron_uri_parse_tag ⚠ aeron_uri_sprint ⚠ aeron_uri_string_builder_close ⚠ aeron_uri_string_builder_get ⚠ aeron_uri_string_builder_init_new ⚠ aeron_uri_string_builder_init_on_string ⚠ aeron_uri_string_builder_put ⚠ aeron_uri_string_builder_put_int32 ⚠ aeron_uri_string_builder_put_int64 ⚠ aeron_uri_string_builder_set_initial_position ⚠ aeron_uri_string_builder_sprint ⚠ aeron_usable_fs_space ⚠ aeron_usable_fs_space_disabled ⚠ aeron_version_full ⚠ Return full version and build string. aeron_version_gitsha ⚠ Return the git sha for the current build. aeron_version_major ⚠ Return major version number. aeron_version_minor ⚠ Return minor version number. aeron_version_patch ⚠ Return patch version number. aeron_version_text ⚠ Return version text. __builtin_va_list __darwin_pthread_attr_t __darwin_pthread_cond_t __darwin_pthread_mutex_t __darwin_pthread_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_async_destination_by_id_t aeron_async_destination_t aeron_async_get_next_available_session_id_t aeron_block_handler_t Callback for handling a block of messages being read from a log. aeron_buffer_claim_t Structure used to hold information for a try_claim function call. aeron_clock_func_t Clock function used by aeron. aeron_cnc_constants_t aeron_cnc_metadata_t aeron_cnc_t aeron_cond_t aeron_context_t aeron_controlled_fragment_assembler_t aeron_controlled_fragment_handler_t Callback for handling fragments of data being read from a log. aeron_counter_constants_t Configuration for a counter that does not change during its lifetime. aeron_counter_metadata_descriptor_t aeron_counter_t aeron_counter_value_descriptor_t aeron_counters_reader_buffers_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_t aeron_data_header_as_longs_t aeron_data_header_t aeron_error_handler_t The error handler to be called when an error occurs. aeron_error_log_reader_func_t aeron_error_t aeron_exclusive_publication_t aeron_fprintf_handler_t aeron_fptr_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_header_t aeron_header_values_frame_t aeron_header_values_t aeron_idle_strategy_func_t aeron_idle_strategy_init_func_t aeron_idle_strategy_t aeron_image_constants_t Configuration for an image that does not change during it’s lifetime. aeron_image_controlled_fragment_assembler_t aeron_image_fragment_assembler_t aeron_image_t aeron_iovec_t aeron_ipc_channel_params_t aeron_log_buffer_t aeron_log_func_t Function to return logging information. aeron_logbuffer_metadata_t aeron_loss_reporter_entry_offset_t aeron_loss_reporter_entry_t aeron_loss_reporter_read_entry_func_t aeron_loss_reporter_t aeron_mapped_buffer_t aeron_mapped_file_t aeron_mapped_raw_log_t aeron_mutex_t aeron_nak_header_t aeron_notification_t Generalised notification callback. aeron_on_available_counter_pair_t aeron_on_available_counter_t Function called by aeron_client_t to deliver notifications that a counter has been added to the driver. 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_pair_t aeron_on_close_client_t Function called by aeron_client_t to deliver notifications that the client is closing. 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_pair_t aeron_on_unavailable_counter_t Function called by aeron_client_t to deliver notifications that a counter has been removed from the driver. aeron_on_unavailable_image_t Function called by aeron_client_t to deliver notifications that an aeron_image_t has been removed from use and
should not be used any longer. aeron_option_header_t aeron_per_thread_error_t aeron_publication_constants_t Configuration for a publication that does not change during it’s lifetime. aeron_publication_error_frame_handler_t The error frame handler to be called when the driver notifies the client about an error frame being received.
The data passed to this callback will only be valid for the lifetime of the callback. The user should use
aeron_publication_error_values_copy if they require the data to live longer than that. aeron_publication_error_values_t aeron_publication_t aeron_raw_log_free_func_t aeron_raw_log_map_func_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_response_setup_header_t aeron_rttm_header_t aeron_setup_header_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_subscription_constants_t aeron_subscription_t aeron_t aeron_thread_attr_t aeron_thread_t aeron_udp_channel_params_t aeron_uri_param_t aeron_uri_params_t aeron_uri_parse_callback_t aeron_uri_string_builder_t aeron_uri_t aeron_usable_fs_space_func_t pthread_attr_t pthread_cond_t pthread_mutex_t pthread_t va_list aeron_uri_stct__bindgen_ty_1