blob: d83b4309daa880cb8ff3fe75bd5ec84ac976a0ce (
plain)
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
61
62
63
64
65
|
// SPDX-License-Identifier: GPL-3.0-or-later
package logs
import (
"errors"
"fmt"
"io"
"strconv"
)
type ParseError struct {
msg string
err error
}
func (e ParseError) Error() string { return e.msg }
func (e ParseError) Unwrap() error { return e.err }
func IsParseError(err error) bool { var v *ParseError; return errors.As(err, &v) }
type (
LogLine interface {
Assign(name string, value string) error
}
Parser interface {
ReadLine(LogLine) error
Parse(row []byte, line LogLine) error
Info() string
}
)
const (
TypeCSV = "csv"
TypeLTSV = "ltsv"
TypeRegExp = "regexp"
TypeJSON = "json"
)
type ParserConfig struct {
LogType string `yaml:"log_type" json:"log_type"`
CSV CSVConfig `yaml:"csv_config" json:"csv_config"`
LTSV LTSVConfig `yaml:"ltsv_config" json:"ltsv_config"`
RegExp RegExpConfig `yaml:"regexp_config" json:"regexp_config"`
JSON JSONConfig `yaml:"json_config" json:"json_config"`
}
func NewParser(config ParserConfig, in io.Reader) (Parser, error) {
switch config.LogType {
case TypeCSV:
return NewCSVParser(config.CSV, in)
case TypeLTSV:
return NewLTSVParser(config.LTSV, in)
case TypeRegExp:
return NewRegExpParser(config.RegExp, in)
case TypeJSON:
return NewJSONParser(config.JSON, in)
default:
return nil, fmt.Errorf("invalid type: %q", config.LogType)
}
}
func isNumber(s string) bool { _, err := strconv.Atoi(s); return err == nil }
|
