Struct rusteron_media_driver::AeronReceiveChannelEndpoint

pub struct AeronReceiveChannelEndpoint { /* private fields */ }

Implementations

impl AeronReceiveChannelEndpoint

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

pub fn conductor_fields( &self, ) -> aeron_receive_channel_endpoint_stct_aeron_receive_channel_endpoint_conductor_fields_stct

pub fn destinations( &self, ) -> aeron_receive_channel_endpoint_stct_destination_stct

pub fn dispatcher(&self) -> AeronDataPacketDispatcher

pub fn stream_id_to_refcnt_map(&self) -> AeronInt64CounterMap

pub fn stream_and_session_id_to_refcnt_map(&self) -> AeronInt64CounterMap

pub fn response_stream_id_to_refcnt_map(&self) -> AeronInt64CounterMap

pub fn channel_status(&self) -> AeronAtomicCounter

pub fn receiver_proxy(&self) -> AeronDriverReceiverProxy

pub fn transport_bindings(&self) -> *mut aeron_udp_channel_transport_bindings_t

pub fn cached_clock(&self) -> AeronClockCache

pub fn send_nak_message(&self) -> aeron_driver_send_nak_message_func_t

pub fn receiver_id(&self) -> i64

pub fn has_receiver_released(&self) -> bool

pub fn group_tag(&self) -> aeron_receive_channel_endpoint_stct__bindgen_ty_1

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

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

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

pub fn close(&self) -> Result<i32, AeronCError>

pub fn send( &self, destination: &AeronReceiveDestination, address: &SockaddrStorage, iov: &Iovec, ) -> Result<i32, AeronCError>

pub fn elicit_setup( &self, stream_id: i32, session_id: i32, ) -> Result<i32, AeronCError>

pub fn send_sm( &self, destination: &AeronReceiveDestination, control_addr: &SockaddrStorage, stream_id: i32, session_id: i32, term_id: i32, term_offset: i32, receiver_window: i32, flags: u8, ) -> Result<i32, AeronCError>

pub fn send_nak( &self, destination: &AeronReceiveDestination, addr: &SockaddrStorage, stream_id: i32, session_id: i32, term_id: i32, term_offset: i32, length: i32, ) -> Result<i32, AeronCError>

pub fn send_rttm( &self, destination: &AeronReceiveDestination, addr: &SockaddrStorage, stream_id: i32, session_id: i32, echo_timestamp: i64, reception_delta: i64, is_reply: bool, ) -> Result<i32, AeronCError>

pub fn send_response_setup( &self, destination: &AeronReceiveDestination, addr: &SockaddrStorage, stream_id: i32, session_id: i32, response_session_id: i32, ) -> Result<i32, AeronCError>

pub fn aeron_receiver_channel_endpoint_send_error_frame( &self, destination: &AeronReceiveDestination, control_addr: &SockaddrStorage, session_id: i32, stream_id: i32, error_code: i32, invalidation_reason: &str, ) -> Result<i32, AeronCError>

pub fn on_data( &self, destination: &AeronReceiveDestination, buffer: &mut [u8], addr: &SockaddrStorage, media_receive_timestamp: &Timespec, ) -> Result<i32, AeronCError>

pub fn on_setup( &self, destination: &AeronReceiveDestination, buffer: &mut [u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn on_rttm( &self, destination: &AeronReceiveDestination, buffer: &mut [u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn on_unconnected_stream( &self, destination: &AeronReceiveDestination, buffer: &mut [u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn try_remove_endpoint(&self)

pub fn incref_to_stream(&self, stream_id: i32) -> Result<i32, AeronCError>

pub fn decref_to_stream(&self, stream_id: i32) -> Result<i32, AeronCError>

pub fn incref_to_stream_and_session( &self, stream_id: i32, session_id: i32, ) -> Result<i32, AeronCError>

pub fn decref_to_stream_and_session( &self, stream_id: i32, session_id: i32, ) -> Result<i32, AeronCError>

pub fn incref_to_response_stream( &self, stream_id: i32, ) -> Result<i32, AeronCError>

pub fn decref_to_response_stream( &self, stream_id: i32, ) -> Result<i32, AeronCError>

pub fn on_add_subscription(&self, stream_id: i32) -> Result<i32, AeronCError>

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

pub fn on_add_subscription_by_session( &self, stream_id: i32, session_id: i32, ) -> Result<i32, AeronCError>

pub fn on_remove_subscription_by_session( &self, stream_id: i32, session_id: i32, ) -> Result<i32, AeronCError>

pub fn add_destination( &self, destination: &AeronReceiveDestination, ) -> Result<i32, AeronCError>

pub fn on_add_publication_image( &self, image: &AeronPublicationImage, ) -> Result<i32, AeronCError>

pub fn on_remove_publication_image( &self, image: &AeronPublicationImage, ) -> Result<i32, AeronCError>

pub fn aeron_receiver_channel_endpoint_validate_sender_mtu_length( &self, sender_mtu_length: usize, window_max_length: usize, ctx: &AeronDriverContext, ) -> Result<i32, AeronCError>

pub fn check_for_re_resolution( &self, now_ns: i64, conductor_proxy: &AeronDriverConductorProxy, )

pub fn update_control_address( &self, destination: &AeronReceiveDestination, address: &SockaddrStorage, )

pub fn add_poll_transports( &self, poller: *mut aeron_udp_transport_poller_t, ) -> Result<i32, AeronCError>

pub fn remove_poll_transports( &self, poller: *mut aeron_udp_transport_poller_t, ) -> Result<i32, AeronCError>

pub fn add_pending_setup( &self, receiver: &AeronDriverReceiver, session_id: i32, stream_id: i32, ) -> Result<i32, AeronCError>

pub fn add_pending_setup_destination( &self, receiver: &AeronDriverReceiver, destination: &AeronReceiveDestination, session_id: i32, stream_id: i32, ) -> Result<i32, AeronCError>

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

Trait Implementations

impl Clone for AeronReceiveChannelEndpoint

fn clone(&self) -> AeronReceiveChannelEndpoint

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronReceiveChannelEndpoint

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

Formats the value using the given formatter.

impl Deref for AeronReceiveChannelEndpoint

type Target = aeron_receive_channel_endpoint_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronReceiveChannelEndpoint> for *mut aeron_receive_channel_endpoint_t

fn from(value: &AeronReceiveChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<*const aeron_receive_channel_endpoint_stct> for AeronReceiveChannelEndpoint

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

Converts to this type from the input type.

impl From<*mut aeron_receive_channel_endpoint_stct> for AeronReceiveChannelEndpoint

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

Converts to this type from the input type.

impl From<AeronReceiveChannelEndpoint> for *mut aeron_receive_channel_endpoint_t

fn from(value: AeronReceiveChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<AeronReceiveChannelEndpoint> for aeron_receive_channel_endpoint_t

fn from(value: AeronReceiveChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<aeron_receive_channel_endpoint_stct> for AeronReceiveChannelEndpoint

fn from(value: aeron_receive_channel_endpoint_t) -> Self

Converts to this type from the input type.