Enum PacketDecoder 

pub enum PacketDecoder {
    Stream {
        stream: Box<dyn BufRead + Send>,
        is_eof: bool,
        counters: ProtocolCounters,
    },
    Socket {
        socket: UdpSocket,
        is_eof: bool,
        counters: ProtocolCounters,
        last_seq_num: u16,
        partial_packet_info: Option<UdpParserState>,
        read_buffer: Vec<u8>,
        last_recv_time: Option<Instant>,
    },
}

Variants

Stream

Fields

stream: Box<dyn BufRead + Send>

is_eof: bool

counters: ProtocolCounters

Socket

Fields

socket: UdpSocket

is_eof: bool

counters: ProtocolCounters

last_seq_num: u16

partial_packet_info: Option<UdpParserState>

read_buffer: Vec<u8>

last_recv_time: Option<Instant>

Implementations

impl PacketDecoder

pub fn from_stream(stream: impl Read + Send + 'static) -> Self

pub fn from_socket(addr: impl ToSocketAddrs) -> Self

pub fn read_packet(&mut self) -> ReadResult<Option<Packet>>

pub fn is_eof(&self) -> bool

pub fn counters(&self) -> ProtocolCounters