func()

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
}