Struct NetflowServer 

pub struct NetflowServer {
    pub initial_template_received: bool,
    pub socket: UdpSocket,
    pub receive_buffer: [u8; 2500],
    pub senders: Vec<NetflowSender>,
    pub db_conn: Arc<Mutex<Connection>>,
    /* private fields */
}

Fields

initial_template_received: bool

socket: UdpSocket

receive_buffer: [u8; 2500]

senders: Vec<NetflowSender>

db_conn: Arc<Mutex<Connection>>

Implementations

impl NetflowServer

pub fn new(addr_and_port: String, db_conn_srv: Arc<Mutex<Connection>>) -> Self

pub fn run(&mut self)

pub fn update_or_create_sender( &mut self, source_address: SocketAddr, template: NetflowTemplate, )

pub fn start_receiving(&mut self) -> SocketAddr

pub fn parse_flow_length(&self, message: &[u8]) -> u16

pub fn parse_flow_template_id_from_template(&self, message: &[u8]) -> u16

pub fn parse_flow_template_id_from_data(&self, message: &[u8]) -> u16

pub fn parse_flow_field_count(&self, message: &[u8]) -> u16

pub fn parse_flow_template(&mut self) -> NetflowTemplate

pub fn parse_data_to_packet(&mut self, byte_count: usize, sender_index: usize)

pub fn determine_packet_type(&self) -> PacketType

pub fn wait_for_initial_template(&mut self) -> SocketAddr

pub fn wait_for_netflow_data(&mut self) -> SocketAddr

pub fn match_sender(&mut self, sender_ip: Ipv4Addr) -> Result<usize, Error>