logparser

Sep 29, 2023

Changes in this version

type LogEntry

+ Timestamp time.Time

type Message

+ Timestamp time.Time

+ type OnMsgCallbackF func(ts time.Time, level Level, patternHash string, msg string)

Feb 4, 2022

Changes in this version

+ type CriDecoder struct

+ func (d CriDecoder) Decode(src string) (string, error)

+ type Decoder interface

+ Decode func(string) (string, error)

+ type DockerJsonDecoder struct

+ func (d DockerJsonDecoder) Decode(src string) (string, error)

+ type DockerLogJson struct

+ Log string

+ type Level int

+ const LevelCritical

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelUnknown

+ const LevelWarning

+ func GuessLevel(line string) Level

+ func LevelByPriority(priority string) Level

+ func (l Level) String() string

+ type LogCounter struct

+ Hash string

+ Level Level

+ Messages int

+ Sample string

+ type LogEntry struct

+ Content string

+ Level Level

+ type Message struct

+ Content string

+ Level Level

+ type MultilineCollector struct

+ Messages chan Message

+ func NewMultilineCollector(ctx context.Context, timeout time.Duration) *MultilineCollector

+ func (m *MultilineCollector) Add(entry LogEntry)

+ type Parser struct

+ func NewParser(ch <-chan LogEntry, decoder Decoder) *Parser

+ func (p *Parser) GetCounters() []LogCounter

+ func (p *Parser) Stop()

+ type Pattern struct

+ func NewPattern(input string) *Pattern

+ func (p *Pattern) Hash() string

+ func (p *Pattern) String() string

+ func (p *Pattern) WeakEqual(other *Pattern) bool