Versions in this module Expand all Collapse all v1 v1.0.0 Dec 8, 2025 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 + Timestamp time.Time + type Message struct + Content string + Level Level + Timestamp time.Time + type MultilineCollector struct + Messages chan Message + func NewMultilineCollector(ctx context.Context, timeout time.Duration, limit int) *MultilineCollector + func (m *MultilineCollector) Add(entry LogEntry) + type OnMsgCallbackF func(ts time.Time, level Level, patternHash string, msg string) + type Parser struct + func NewParser(ch <-chan LogEntry, decoder Decoder, onMsgCallback OnMsgCallbackF, ...) *Parser + func (p *Parser) GetCounters() []LogCounter + func (p *Parser) Stop() + type Pattern struct + func NewPattern(input string) *Pattern + func NewPatternFromWords(input string) *Pattern + func (p *Pattern) Hash() string + func (p *Pattern) String() string + func (p *Pattern) WeakEqual(other *Pattern) bool