Struct JsonImportSource 

pub struct JsonImportSource<R: BufRead> {
    reader: R,
    buffer: Vec<ImportedMemory>,
    buffer_index: usize,
    started: bool,
    array_mode: bool,
    line_number: usize,
}

JSON import source.

Automatically detects and handles both formats:

• NDJSON/JSONL: One JSON object per line
• Array: A JSON array of objects [{...}, {...}]

Fields

reader: R

buffer: Vec<ImportedMemory>

Buffered memories when parsing array format.

buffer_index: usize

Current index into buffer (for array format).

started: bool

Whether we’ve detected and started parsing.

array_mode: bool

Whether we’re in array mode.

line_number: usize

Line number for error reporting.

Implementations

impl<R: BufRead> JsonImportSource<R>

pub const fn new(reader: R) -> Self

Creates a new JSON import source.

fn detect_format(&mut self) -> Result<bool>

Peeks at the first non-whitespace character to detect format.

Trait Implementations

impl<R: BufRead> ImportSource for JsonImportSource<R>

fn next(&mut self) -> Result<Option<ImportedMemory>>

Reads the next memory from the source.

fn size_hint(&self) -> Option<usize>

Returns an estimate of the total number of records.