in logger/common.go [367:391]
func (l *Logger) sendLogMsgToDest(
line []byte,
source string,
isFirstPartial, isPartialMsg bool,
partialTimestamp time.Time,
) (error, time.Time, bool, bool) {
msgTimestamp, partialTimestamp, isFirstPartial, isPartialMsg := getLogTimestamp(
isFirstPartial,
isPartialMsg,
partialTimestamp,
l.Info.ContainerID,
)
if debug.Verbose {
debug.SendEventsToLog(l.Info.ContainerID,
fmt.Sprintf("[Pipe %s] Scanned message: %s", source, string(line)),
debug.DEBUG, 0)
}
err := l.Log(line, source, msgTimestamp)
if err != nil {
return err, partialTimestamp, isFirstPartial, isPartialMsg
}
return nil, partialTimestamp, isFirstPartial, isPartialMsg
}