Skip to main content

parse_bulk_op

Function parse_bulk_op 

Source
pub fn parse_bulk_op(
    action_line: &[u8],
    source_line: Option<&[u8]>,
) -> Result<BulkItem, RewriteError>
Expand description

Parses one bulk operation from its already-framed action line and (for source-bearing verbs) source line, the per-op entry point for the streaming demux (ADR-014 stage 4). The source line is kept as raw bytes, validated but not materialized, exactly as parse_bulk does.

ยงErrors

RewriteError::MalformedBulkAction if a source-bearing action has no source line, RewriteError::InvalidJson if a line is not valid JSON.