[−][src]Trait aeron_rs::driver_listener_adapter::DriverListener

pub trait DriverListener {
    fn on_new_publication(
        &mut self, 
        registration_id: i64, 
        original_registration_id: i64, 
        stream_id: i32, 
        session_id: i32, 
        publication_limit_counter_id: i32, 
        channel_status_indicator_id: i32, 
        log_filename: CString
    );

    fn on_new_exclusive_publication(
        &mut self, 
        registration_id: i64, 
        original_registration_id: i64, 
        stream_id: i32, 
        session_id: i32, 
        publication_limit_counter_id: i32, 
        channel_status_indicator_id: i32, 
        log_filename: CString
    );

    fn on_subscription_ready(
        &mut self, 
        registration_id: i64, 
        channel_status_id: i32
    );

    fn on_operation_success(&mut self, correlation_id: i64);

    fn on_channel_endpoint_error_response(
        &mut self, 
        offending_command_correlation_id: i64, 
        error_message: CString
    );

    fn on_error_response(
        &mut self, 
        offending_command_correlation_id: i64, 
        error_code: i32, 
        error_message: CString
    );

    fn on_available_image(
        &mut self, 
        correlation_id: i64, 
        session_id: i32, 
        subscriber_position_id: i32, 
        subscription_registration_id: i64, 
        log_filename: CString, 
        source_identity: CString
    );

    fn on_unavailable_image(
        &mut self, 
        correlation_id: i64, 
        subscription_registration_id: i64
    );

    fn on_available_counter(&mut self, registration_id: i64, counter_id: i32);

    fn on_unavailable_counter(&mut self, registration_id: i64, counter_id: i32);

    fn on_client_timeout(&mut self, client_id: i64);
}

Required methods

fn on_new_publication(
    &mut self,
    registration_id: i64,
    original_registration_id: i64,
    stream_id: i32,
    session_id: i32,
    publication_limit_counter_id: i32,
    channel_status_indicator_id: i32,
    log_filename: CString
)

fn on_new_exclusive_publication(
    &mut self,
    registration_id: i64,
    original_registration_id: i64,
    stream_id: i32,
    session_id: i32,
    publication_limit_counter_id: i32,
    channel_status_indicator_id: i32,
    log_filename: CString
)

fn on_subscription_ready(
    &mut self,
    registration_id: i64,
    channel_status_id: i32
)

fn on_operation_success(&mut self, correlation_id: i64)

fn on_channel_endpoint_error_response(
    &mut self,
    offending_command_correlation_id: i64,
    error_message: CString
)

fn on_error_response(
    &mut self,
    offending_command_correlation_id: i64,
    error_code: i32,
    error_message: CString
)

fn on_available_image(
    &mut self,
    correlation_id: i64,
    session_id: i32,
    subscriber_position_id: i32,
    subscription_registration_id: i64,
    log_filename: CString,
    source_identity: CString
)

fn on_unavailable_image(
    &mut self,
    correlation_id: i64,
    subscription_registration_id: i64
)

fn on_available_counter(&mut self, registration_id: i64, counter_id: i32)

fn on_unavailable_counter(&mut self, registration_id: i64, counter_id: i32)

fn on_client_timeout(&mut self, client_id: i64)

Loading content...

Implementors

impl DriverListener for ClientConductor[src]

Loading content...