parser

package

Go to main page

Versions in this module

v1

v1.4.2

Jan 4, 2018

v1.4.1

Dec 7, 2017

Changes in this version

+ const KeyAutoRename

+ const KeyRFCType

+ const SyslogEofLine

+ const TypeSyslog

+ var OptionTimezoneOffset = utils.Option

+ func DetectType(data []byte) (detected int)

+ type Automatic struct

+ func (f *Automatic) GetParser(line []byte) SysLogParser

+ func (f *Automatic) IsNewLine(data []byte) bool

type CsvParser

+ func (p *CsvParser) Rename(datas []sender.Data) []sender.Data

+ func (p *CsvParser) Type() string

+ type Format interface

+ GetParser func([]byte) SysLogParser

+ IsNewLine func(data []byte) bool

+ func GetFormt(format string) Format

type GrokParser

+ func (gp *GrokParser) Type() string

type JsonParser

+ func (im *JsonParser) Type() string

type KafaRestlogParser

+ func (krp *KafaRestlogParser) Type() string

type LogParser

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

+ type LogParts map[string]interface

type NginxParser

+ func (p *NginxParser) Type() string

+ type ParserType interface

+ Type func() string

type QiniulogParser

+ func (p *QiniulogParser) Type() string

+ type RFC3164 struct

+ func (f *RFC3164) GetParser(line []byte) SysLogParser

+ func (f *RFC3164) IsNewLine(data []byte) bool

+ type RFC5424 struct

+ func (f *RFC5424) GetParser(line []byte) SysLogParser

+ func (f *RFC5424) IsNewLine(data []byte) bool

+ type RFC6587 struct

+ func (f *RFC6587) GetParser(line []byte) SysLogParser

+ func (f *RFC6587) IsNewLine(data []byte) bool

type RawlogParser

+ func (p *RawlogParser) Type() string

+ type SysLogParser interface

+ Dump func() LogParts

+ Location func(*time.Location)

+ Parse func() error

+ type SyslogParser struct

+ func (p *SyslogParser) Name() string

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

+ func (p *SyslogParser) Type() string

v1.3.5

Oct 31, 2017

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 NginxConfPath

+ const NginxFormatRegex

+ 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