Versions in this module Expand all Collapse all v1 v1.3.4 Sep 18, 2021 v1.3.3 Dec 28, 2020 v1.3.2 Oct 15, 2020 v1.3.1 Aug 2, 2019 Changes in this version + const NILVALUE + const NO_VERSION + const PRI_PART_END + const PRI_PART_START + const SYSLOG_DELIMITER + var ErrDayInvalid = &ParserError + var ErrEOL = &ParserError + var ErrHourInvalid = &ParserError + var ErrInvalidAppName = &ParserError + var ErrInvalidMsgId = &ParserError + var ErrInvalidProcId = &ParserError + var ErrInvalidTimeFormat = &ParserError + var ErrMinuteInvalid = &ParserError + var ErrMonthInvalid = &ParserError + var ErrNoSpace = &ParserError + var ErrNoStructuredData = &ParserError + var ErrPriorityEmpty = &ParserError + var ErrPriorityNoEnd = &ParserError + var ErrPriorityNoStart = &ParserError + var ErrPriorityNonDigit = &ParserError + var ErrPriorityTooLong = &ParserError + var ErrPriorityTooShort = &ParserError + var ErrSecFracInvalid = &ParserError + var ErrSecondInvalid = &ParserError + var ErrTimeZoneInvalid = &ParserError + var ErrTimestampUnknownFormat = &ParserError + var ErrVersionNotFound = &ParserError + var ErrYearInvalid = &ParserError + func IsDigit(c byte) bool + func Parse2Digits(bs []byte, min int, max int, e error) ([]byte, int, error) + func ParseHostname(bs []byte) ([]byte, string) + func ParseTag(bs []byte) ([]byte, string) + func ParseTimestamp(bs []byte) ([]byte, time.Time, error) + func ParseVersion(bs []byte) ([]byte, int, error) + func ShowCursorPos(buff []byte, cursor int) + func ValidFormat(format string) bool + type Collector interface + Addr func() net.Addr + Start func(chan<- ekanite.Document) error + func NewCollector(proto, iface, format string, tlsConfig *tls.Config) (Collector, error) + type Event struct + Parsed map[string]interface{} + ReceptionTime time.Time + Sequence int64 + SourceIP string + Text string + func (e *Event) Data() interface{} + func (e *Event) ID() ekanite.DocID + func (e *Event) ReferenceTime() time.Time + type Facility struct + Value int + type LogParser struct + Raw []byte + Result map[string]interface{} + func NewLogParser(f string) (*LogParser, error) + func (p *LogParser) Parse(address string, b []byte) + type NetstrDelimiter struct + Result string + func NewNetstrDelimiter() *NetstrDelimiter + func (d *NetstrDelimiter) Push(b byte) (bool, error) + func (d *NetstrDelimiter) Reset() + type Parser interface + Parse func(bs []byte) (map[string]interface{}, error) + func CreateParser(format string) Parser + type ParserError struct + ErrorString string + func (err *ParserError) Error() string + type Priority struct + F Facility + P int + S Severity + func ParsePriority(bs []byte) ([]byte, Priority, error) + type RFC5424V2 struct + type Severity struct + Value int + type SyslogDelimiter struct + func NewSyslogDelimiter(maxSize int) *SyslogDelimiter + func (s *SyslogDelimiter) Push(b byte) (string, bool) + func (s *SyslogDelimiter) Vestige() (string, bool) + type TCPCollector struct + func (s *TCPCollector) Addr() net.Addr + func (s *TCPCollector) Start(c chan<- ekanite.Document) error + type UDPCollector struct + func (s *UDPCollector) Addr() net.Addr + func (s *UDPCollector) Start(c chan<- ekanite.Document) error