parser

package

Go to main page

Versions in this module

v1

v1.3.1

Sep 13, 2017

v1.3.0

Sep 5, 2017

v1.2.4

Aug 29, 2017

v1.2.3

Aug 16, 2017

Changes in this version

+ var ModeKeyOptions = map[string][]utils.Option

+ var ModeUsages = []utils.KeyValue

+ var SampleLogs = map[string]string

v1.2.2

Aug 1, 2017

Changes in this version

+ const NginxFormatRegex

v1.2.1

Jul 18, 2017

Changes in this version

+ const NginxConfPath

+ const NginxLogFormat

+ const NginxSchema

+ const TypeNginx

type CsvType

+ const TypeDate

+ type Label struct

+ Name string

+ Value string

+ func GetLabels(labelList []string, nameMap map[string]struct{}) (labels []Label)

type LogParser

+ func NewNginxParser(c conf.MapConf) (LogParser, error)

+ type NginxParser struct

+ func NewNginxAccParser(c conf.MapConf) (*NginxParser, error)

+ func (p *NginxParser) Name() string

+ func (p *NginxParser) Parse(lines []string) ([]sender.Data, error)

v1.1.0

Jun 27, 2017

Changes in this version

+ const DATE

+ const DEFAULT_PATTERNS

+ const DROP

+ const EMPTY_STRING

+ const FLOAT

+ const KEY_CODE

+ const KEY_DURATION

+ const KEY_ERROR

+ const KEY_LOG_TIME

+ const KEY_METHOD

+ const KEY_RESP_LEN

+ const KEY_SRC_IP

+ const KEY_TOPIC

+ const KEY_WARN

+ const KeyCSVLabels

+ const KeyCSVSchema

+ const KeyCSVSplitter

+ const KeyGrokCustomPatternFiles

+ const KeyGrokCustomPatterns

+ const KeyGrokMode

+ const KeyGrokPatterns

+ const KeyLabels

+ const KeyLogHeaders

+ const KeyLogMaxLine

+ const KeyParserName

+ const KeyParserType

+ const KeyQiniulogPrefix

+ const KeyRaw

+ const KeyRunnerName

+ const KeyTimeZoneOffset

+ const KeyTimestamp

+ const LONG

+ const LogHeadDate

+ const LogHeadFile

+ const LogHeadLevel

+ const LogHeadLog

+ const LogHeadPrefix

+ const LogHeadReqid

+ const LogHeadTime

+ const MaxGrokMultiLineBuffer

+ const MaxParserSchemaErrOutput

+ const ModeMulti

+ const SECOND_PER_5MIN

+ const SECOND_PER_DAY

+ const STRING

+ const TypeCSV

+ const TypeEmpty

+ const TypeGrok

+ const TypeInnerMysql

+ const TypeInnerSQL

+ const TypeJson

+ const TypeKafkaRest

+ const TypeLogv1

+ const TypeRaw

+ var CompliedPatterns map[string]*regexp.Regexp

+ var HeaderPattern = map[string]string

+ func Time1Day(t int64) string

+ func Time1DayInt(t int64) int64

+ func Time5Min(t int64) string

+ func Time5MinInt(t int64) int64

+ type CsvParser struct

+ func (p *CsvParser) Name() string

+ func (p *CsvParser) Parse(lines []string) ([]sender.Data, error)

+ type CsvType string

+ const TypeFloat

+ const TypeJsonMap

+ const TypeLong

+ const TypeString

+ type EmptyParser struct

+ func (p *EmptyParser) Name() string

+ func (p *EmptyParser) Parse(lines []string) (datas []sender.Data, err error)

+ type GrokParser struct

+ CustomPatternFiles []string

+ CustomPatterns string

+ Patterns []string

+ func (gp *GrokParser) Name() string

+ func (gp *GrokParser) Parse(lines []string) ([]sender.Data, error)

+ type JsonParser struct

+ func (im *JsonParser) Name() string

+ func (im *JsonParser) Parse(lines []string) ([]sender.Data, error)

+ type KafaRestlogParser struct

+ func (krp *KafaRestlogParser) Name() string

+ func (krp *KafaRestlogParser) Parse(lines []string) ([]sender.Data, error)

+ func (krp *KafaRestlogParser) ParseCode(fields []string) int

+ func (krp *KafaRestlogParser) ParseDuration(fields []string) int

+ func (krp *KafaRestlogParser) ParseIp(fields []string) string

+ func (krp *KafaRestlogParser) ParseLogTime(fields []string) int64

+ func (krp *KafaRestlogParser) ParseMethod(fields []string) string

+ func (krp *KafaRestlogParser) ParseRespCL(fields []string) int

+ func (krp *KafaRestlogParser) ParseTopic(fields []string) string

+ type LogParser interface

+ Name func() string

+ Parse func(lines []string) (datas []sender.Data, err error)

+ func NewCsvParser(c conf.MapConf) (LogParser, error)

+ func NewEmptyParser(c conf.MapConf) (LogParser, error)

+ func NewGrokParser(c conf.MapConf) (LogParser, error)

+ func NewJsonParser(c conf.MapConf) (LogParser, error)

+ func NewKafaRestlogParser(c conf.MapConf) (LogParser, error)

+ func NewQiniulogParser(c conf.MapConf) (LogParser, error)

+ func NewRawlogParser(c conf.MapConf) (LogParser, error)

+ type ParserRegistry struct

+ func NewParserRegistry() *ParserRegistry

+ func (ps *ParserRegistry) NewLogParser(conf conf.MapConf) (p LogParser, err error)

+ func (ps *ParserRegistry) RegisterParser(parserType string, constructor func(conf.MapConf) (LogParser, error)) error

+ type QiniulogParser struct

+ func (p *QiniulogParser) GetParser(head string) (func(string) (string, string, error), error)

+ func (p *QiniulogParser) Name() string

+ func (p *QiniulogParser) Parse(lines []string) ([]sender.Data, error)

+ type RawlogParser struct

+ func (p *RawlogParser) Name() string

+ func (p *RawlogParser) Parse(lines []string) ([]sender.Data, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL