Function parse_line

nodedb/src/engine/timeseries/ilp.rs:74–111

Parse a single ILP line. Format: `measurement[,tag=val]* field=val[,field=val]* [timestamp]`

(line: &str)

///
/// Format: `measurement[,tag=val]* field=val[,field=val]* [timestamp]`
pub fn parse_line(line: &str) -> Result<IlpLine<'_>, IlpError> {
    let line = line.trim();
    if line.is_empty() || line.starts_with('#') {
        return Err(IlpError::EmptyLine);
    }

    // Split into: measurement+tags, fields, optional timestamp.
    // First space separates measurement+tags from fields.
    let first_space = line.find(' ').ok_or(IlpError::MissingFields)?;
    let measurement_tags = &line[..first_space];
    let rest = line[first_space + 1..].trim_start();

    // Parse measurement and tags.
    let (measurement, tags) = parse_measurement_tags(measurement_tags)?;

    // Split fields from optional timestamp (last space).
    let (fields_str, timestamp_ns) = if let Some(last_space) = rest.rfind(' ') {
        let maybe_ts = &rest[last_space + 1..];
        match maybe_ts.parse::<i64>() {
            Ok(ts) => (&rest[..last_space], Some(ts)),
            Err(_) => (rest, None), // Not a valid timestamp — treat all as fields.
        }
    } else {
        (rest, None)
    };

    let fields = parse_fields(fields_str)?;
    if fields.is_empty() {
        return Err(IlpError::MissingFields);
    }

    Ok(IlpLine {
        measurement,
        tags,
        fields,
        timestamp_ns,
    })
}

/// Parse a batch of ILP lines. Skips empty lines and comments.
pub fn parse_batch(input: &str) -> Vec<Result<IlpLine<'_>, IlpError>> {