Struct rusteron_client::AeronAsyncDestination

pub struct AeronAsyncDestination { /* private fields */ }

Implementations

impl AeronAsyncDestination

pub fn aeron_publication_async_add_destination( client: &Aeron, publication: &AeronPublication, uri: &str, ) -> Result<Self, AeronCError>

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

Parameters

• publication to add destination to.

• uri for the destination to add.

Return

0 for success and -1 for error.

pub fn aeron_exclusive_publication_async_add_destination( client: &Aeron, publication: &AeronExclusivePublication, uri: &str, ) -> Result<Self, AeronCError>

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

Parameters

• publication to add destination to.

• uri for the destination to add.

Return

0 for success and -1 for error.

pub fn aeron_subscription_async_add_destination( client: &Aeron, subscription: &AeronSubscription, uri: &str, ) -> Result<Self, AeronCError>

Add a destination manually to a multi-destination-subscription.

Parameters

• subscription to add destination to.

• uri for the destination to add.

Return

0 for success and -1 for error.

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

Poll the completion of the add/remove of a destination to/from a publication.

Return

0 for not complete (try again), 1 for completed successfully, or -1 for an error.

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

Poll the completion of the add/remove of a destination to/from an exclusive publication.

Return

0 for not complete (try again), 1 for completed successfully, or -1 for an error.

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

Poll the completion of add/remove of a destination to/from a subscription.

Return

0 for not complete (try again), 1 for completed successfully, or -1 for an error.

pub fn get_registration_id(&self) -> i64

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).

Return

correlation_id sent to driver.

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

Trait Implementations

impl Clone for AeronAsyncDestination

fn clone(&self) -> AeronAsyncDestination

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronAsyncDestination

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

Formats the value using the given formatter.

impl Deref for AeronAsyncDestination

type Target = aeron_client_registering_resource_stct

The resulting type after dereferencing.

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

Dereferences the value.

impl From<&AeronAsyncDestination> for *mut aeron_async_destination_t

fn from(value: &AeronAsyncDestination) -> Self

Converts to this type from the input type.

impl From<*const aeron_client_registering_resource_stct> for AeronAsyncDestination

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

Converts to this type from the input type.

impl From<*mut aeron_client_registering_resource_stct> for AeronAsyncDestination

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

Converts to this type from the input type.

impl From<AeronAsyncDestination> for *mut aeron_async_destination_t

fn from(value: AeronAsyncDestination) -> Self

Converts to this type from the input type.

impl From<AeronAsyncDestination> for aeron_async_destination_t

fn from(value: AeronAsyncDestination) -> Self

Converts to this type from the input type.

impl From<aeron_client_registering_resource_stct> for AeronAsyncDestination

fn from(value: aeron_async_destination_t) -> Self

Converts to this type from the input type.