Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + const SECOND_PER_5MIN + const SECOND_PER_DAY + func ConvertWebParserConfig(conf conf.MapConf) conf.MapConf + func ParseLine(dataPipeline <-chan ParseInfo, resultChan chan ParseResult, wg *sync.WaitGroup, ...) + func ParseLineDataSlice(dataPipeline <-chan ParseInfo, resultChan chan ParseResult, wg *sync.WaitGroup, ...) + func RegisterConstructor(typ string, c Constructor) + func Time1Day(t int64) string + func Time1DayInt(t int64) int64 + func Time5Min(t int64) string + func Time5MinInt(t int64) int64 + type Constructor func(conf.MapConf) (Parser, error) + type Flushable interface + Flush func() (Data, error) + type ParseInfo struct + Index int + Line string + type ParseResult struct + Data Data + Datas []Data + Err error + Index int + Line string + type ParseResultSlice []ParseResult + func (slice ParseResultSlice) Len() int + func (slice ParseResultSlice) Less(i, j int) bool + func (slice ParseResultSlice) Swap(i, j int) + type Parser interface + Name func() string + Parse func(lines []string) (datas []Data, err error) + type ParserType interface + Type func() string + type Registry struct + func NewRegistry() *Registry + func (ps *Registry) NewLogParser(conf conf.MapConf) (p Parser, err error) + func (ps *Registry) RegisterParser(parserType string, constructor func(conf.MapConf) (Parser, error)) error + type ServerParser interface + ServerConfig func() map[string]interface{}
Go to main page