[−][src]Struct aeron_rs::driver_proxy::DriverProxy

pub struct DriverProxy { /* fields omitted */ }

Methods

impl DriverProxy[src]

pub fn new(to_driver_command_buffer: Arc<ManyToOneRingBuffer>) -> Self[src]

pub fn time_of_last_driver_keepalive(&self) -> i64[src]

pub fn client_id(&self) -> i64[src]

pub fn add_publication(
    &self,
    channel: CString,
    stream_id: i32
) -> Result<i64, AeronError>[src]

pub fn add_exclusive_publication(
    &self,
    channel: CString,
    stream_id: i32
) -> Result<i64, AeronError>[src]

pub fn remove_publication(
    &self,
    registration_id: i64
) -> Result<i64, AeronError>[src]

pub fn add_subscription(
    &self,
    channel: CString,
    stream_id: i32
) -> Result<i64, AeronError>[src]

pub fn remove_subscription(
    &self,
    registration_id: i64
) -> Result<i64, AeronError>[src]

pub fn send_client_keepalive(&self) -> Result<(), AeronError>[src]

pub fn add_destination(
    &self,
    publication_registration_id: i64,
    channel: CString
) -> Result<i64, AeronError>[src]

pub fn remove_destination(
    &self,
    publication_registration_id: i64,
    channel: CString
) -> Result<i64, AeronError>[src]

pub fn add_rcv_destination(
    &self,
    subscription_registration_id: i64,
    channel: CString
) -> Result<i64, AeronError>[src]

pub fn remove_rcv_destination(
    &self,
    subscription_registration_id: i64,
    channel: CString
) -> Result<i64, AeronError>[src]

pub fn add_counter(
    &self,
    type_id: i32,
    key: &[u8],
    label: CString
) -> Result<i64, AeronError>[src]

pub fn remove_counter(&self, registration_id: i64) -> Result<i64, AeronError>[src]

pub fn client_close(&self) -> Result<i64, AeronError>[src]

pub fn terminate_driver(
    &self,
    token_buffer: *const u8,
    token_length: Index
) -> Result<(), AeronError>[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.