NetBlockProcessor

Trait NetBlockProcessor 

Source
pub trait NetBlockProcessor {
    // Required methods
    fn on_connection_begin(
        &mut self,
        event_id: i64,
        time: i64,
        connection_name: Arc<String>,
        is_outgoing: bool,
    ) -> Result<bool, Error>;
    fn on_connection_end(
        &mut self,
        event_id: i64,
        time: i64,
        bit_size: i64,
    ) -> Result<bool, Error>;
    fn on_object_begin(
        &mut self,
        event_id: i64,
        time: i64,
        object_name: Arc<String>,
    ) -> Result<bool, Error>;
    fn on_object_end(
        &mut self,
        event_id: i64,
        time: i64,
        bit_size: i64,
    ) -> Result<bool, Error>;
    fn on_property(
        &mut self,
        event_id: i64,
        time: i64,
        property_name: Arc<String>,
        bit_size: i64,
    ) -> Result<bool, Error>;
    fn on_rpc_begin(
        &mut self,
        event_id: i64,
        time: i64,
        function_name: Arc<String>,
    ) -> Result<bool, Error>;
    fn on_rpc_end(
        &mut self,
        event_id: i64,
        time: i64,
        bit_size: i64,
    ) -> Result<bool, Error>;
}
Expand description

A trait for processing network tracing event blocks.

Implementors receive one callback per decoded net event. Returning Ok(true) continues iteration; returning Ok(false) stops parsing the current block.

Required Methods§

Source

fn on_connection_begin( &mut self, event_id: i64, time: i64, connection_name: Arc<String>, is_outgoing: bool, ) -> Result<bool, Error>

Source

fn on_connection_end( &mut self, event_id: i64, time: i64, bit_size: i64, ) -> Result<bool, Error>

Source

fn on_object_begin( &mut self, event_id: i64, time: i64, object_name: Arc<String>, ) -> Result<bool, Error>

Source

fn on_object_end( &mut self, event_id: i64, time: i64, bit_size: i64, ) -> Result<bool, Error>

Source

fn on_property( &mut self, event_id: i64, time: i64, property_name: Arc<String>, bit_size: i64, ) -> Result<bool, Error>

Source

fn on_rpc_begin( &mut self, event_id: i64, time: i64, function_name: Arc<String>, ) -> Result<bool, Error>

Source

fn on_rpc_end( &mut self, event_id: i64, time: i64, bit_size: i64, ) -> Result<bool, Error>

Implementors§