Struct DnodeParser 

pub struct DnodeParser { /* private fields */ }

Streaming DNODE header parser.

Implementations

impl DnodeParser

pub fn new() -> Self

Build a fresh parser positioned at DynParseState::Start.

Examples

use dynomite::proto::dnode::{DnodeParser, DynParseState};
let p = DnodeParser::new();
assert_eq!(p.state(), DynParseState::Start);

pub fn reset(&mut self)

Reset the parser to DynParseState::Start with a fresh accumulator Dmsg.

pub fn state(&self) -> DynParseState

Current state.

pub fn dmsg(&self) -> &Dmsg

Borrow the partial Dmsg.

pub fn take_dmsg(&mut self) -> Dmsg

Move the parsed Dmsg out of the parser. Only meaningful after a ParseStep::HeaderDone step.

pub fn step(&mut self, input: &[u8]) -> ParseStep

Feed input to the parser. The parser advances as far as it can and returns one of the three ParseStep variants.

The state machine is byte-driven and can be reentered with a fresh slice when ParseStep::NeedMore indicates the input was truncated mid-header.

Examples

use dynomite::proto::dnode::{DnodeParser, ParseStep};
let mut p = DnodeParser::new();
let bytes = b"$2014$ 1 3 0 1 1 *1 d *0\r\n";
match p.step(bytes) {
    ParseStep::HeaderDone { consumed } => assert_eq!(consumed, bytes.len()),
    other => panic!("unexpected: {other:?}"),
}

The state machine intentionally stays in one function to match the reference engine’s single-block parser; splitting the per-state arms across helpers would obscure the parity.

Trait Implementations

impl Debug for DnodeParser

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

Formats the value using the given formatter.

impl Default for DnodeParser

fn default() -> Self

Returns the “default value” for a type.