dm-database-driver-log 0.1.0

A pluggable streaming parser for DM database driver logs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use thiserror::Error;

/// 解析失败的位置与原因。
///
/// `line_number == 0` 表示错误来自独立的解析调用，而不是文件迭代器。
/// 错误只在失败路径保存原文，不影响正常解析路径。
#[derive(Debug, Clone, PartialEq, Eq, Error)]
pub enum ParseError {
    #[error("invalid format at line {line_number}, offset {offset}: {what} | raw: {raw}")]
    InvalidFormat {
        raw: String,
        line_number: u64,
        offset: usize,
        what: &'static str,
    },
    #[error("IO error: {0}")]
    IoError(String),
}

impl ParseError {
    #[cfg(any(feature = "jdbc", feature = "dm-provider"))]
    pub(crate) fn invalid(offset: usize, what: &'static str) -> Self {
        Self::InvalidFormat {
            raw: String::new(),
            line_number: 0,
            offset,
            what,
        }
    }

    pub(crate) fn with_context(mut self, raw: &str, line_number: u64) -> Self {
        if let Self::InvalidFormat {
            raw: saved,
            line_number: saved_line,
            ..
        } = &mut self
        {
            if saved.is_empty() {
                *saved = raw.to_owned();
            }
            *saved_line = line_number;
        }
        self
    }

    pub fn line_number(&self) -> Option<u64> {
        match self {
            Self::InvalidFormat { line_number: 0, .. } => None,
            Self::InvalidFormat { line_number, .. } => Some(*line_number),
            Self::IoError(_) => None,
        }
    }

    pub fn offset(&self) -> Option<usize> {
        match self {
            Self::InvalidFormat { offset, .. } => Some(*offset),
            Self::IoError(_) => None,
        }
    }
}