Struct rusteron_media_driver::AeronSendChannelEndpoint

pub struct AeronSendChannelEndpoint { /* private fields */ }

Implementations

impl AeronSendChannelEndpoint

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

pub fn conductor_fields( &self, ) -> aeron_send_channel_endpoint_stct_aeron_send_channel_endpoint_conductor_fields_stct

pub fn has_sender_released(&self) -> bool

pub fn transport(&self) -> aeron_udp_channel_transport_t

pub fn channel_status(&self) -> AeronAtomicCounter

pub fn local_sockaddr_indicator(&self) -> AeronAtomicCounter

pub fn tracker_num_destinations(&self) -> AeronAtomicCounter

pub fn destination_tracker(&self) -> AeronUdpDestinationTracker

pub fn sender_proxy(&self) -> AeronDriverSenderProxy

pub fn publication_dispatch_map(&self) -> AeronInt64ToPtrHashMap

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

pub fn data_paths(&self) -> AeronUdpChannelDataPaths

pub fn current_data_addr(&self) -> SockaddrStorage

pub fn bind_addr(&self) -> SockaddrStorage

pub fn port_manager(&self) -> AeronPortManager

pub fn cached_clock(&self) -> AeronClockCache

pub fn time_of_last_sm_ns(&self) -> i64

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

pub fn incref(clientd: *mut c_void)

pub fn decref(clientd: *mut c_void)

pub fn aeron_send_channel_send( &self, iov: &Iovec, iov_length: usize, ) -> Result<i64, AeronCError>

pub fn aeron_send_channel_send_endpoint_address( &self, endpoint_address: &SockaddrStorage, iov: &Iovec, iov_length: usize, ) -> Result<i64, AeronCError>

pub fn add_publication( &self, publication: &AeronNetworkPublication, ) -> Result<i32, AeronCError>

pub fn remove_publication( &self, publication: &AeronNetworkPublication, ) -> Result<i32, AeronCError>

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

pub fn on_status_message( &self, conductor_proxy: &AeronDriverConductorProxy, buffer: &mut [u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn on_error( &self, conductor_proxy: &AeronDriverConductorProxy, buffer: &mut [u8], addr: &SockaddrStorage, ) -> Result<i32, AeronCError>

pub fn on_rttm(&self, buffer: &mut [u8], addr: &SockaddrStorage)

pub fn on_response_setup( &self, conductor_proxy: &AeronDriverConductorProxy, buffer: &mut [u8], addr: &SockaddrStorage, )

pub fn check_for_re_resolution( &self, now_ns: i64, conductor_proxy: &AeronDriverConductorProxy, ) -> Result<i32, AeronCError>

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

Trait Implementations

impl Clone for AeronSendChannelEndpoint

fn clone(&self) -> AeronSendChannelEndpoint

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronSendChannelEndpoint

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

Formats the value using the given formatter.

impl Deref for AeronSendChannelEndpoint

type Target = aeron_send_channel_endpoint_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronSendChannelEndpoint> for *mut aeron_send_channel_endpoint_t

fn from(value: &AeronSendChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<*const aeron_send_channel_endpoint_stct> for AeronSendChannelEndpoint

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

Converts to this type from the input type.

impl From<*mut aeron_send_channel_endpoint_stct> for AeronSendChannelEndpoint

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

Converts to this type from the input type.

impl From<AeronSendChannelEndpoint> for *mut aeron_send_channel_endpoint_t

fn from(value: AeronSendChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<AeronSendChannelEndpoint> for aeron_send_channel_endpoint_t

fn from(value: AeronSendChannelEndpoint) -> Self

Converts to this type from the input type.

impl From<aeron_send_channel_endpoint_stct> for AeronSendChannelEndpoint

fn from(value: aeron_send_channel_endpoint_t) -> Self

Converts to this type from the input type.