Struct rmonitor::codec::RMonitorDecoder

pub struct RMonitorDecoder { /* fields omitted */ }

A decoder for RMonitor records, which wraps an underlying LinesCodec to provide framing logic.

Implementations

impl RMonitorDecoder

pub fn new() -> Self

Returns an RMonitorDecoder for decoding RMonitor records from a TCP stream.

Note

The returned RMonitorDecoder will have an underlying LinesCodec with no upper bound on the length of a buffered line. Consider using new_with_max_length instead.

pub fn new_with_max_length(max_length: usize) -> Self

Returns an RMonitorDecoder where the underlying LinesCodec has a maximum line length limit.

It is recommended to set such a limit where the input to be supplied to the decoder is untrusted, as an attacker could send an unbounded amount of input with no newline characters.

Trait Implementations

impl Debug for RMonitorDecoder

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Decoder for RMonitorDecoder

type Item = Record

The type of decoded frames.

type Error = RMonitorCodecError

The type of unrecoverable frame decoding errors.

fn decode(
    &mut self,
    src: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame from the provided buffer of bytes.

fn decode_eof(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

A default method available to be called when there are no more bytes available to be read from the underlying I/O.

fn framed<T>(self, io: T) -> Framed<T, Self> where
    T: AsyncRead + AsyncWrite, 

Provides a [Stream] and [Sink] interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data.

impl Default for RMonitorDecoder

fn default() -> RMonitorDecoder

Returns the "default value" for a type.