Method Writer

pkg/util/log/stream_logger.go:462–483

(level logrus.Level, raw bool)

}

func (s *StreamLogger) Writer(level logrus.Level, raw bool) io.WriteCloser {
	s.m.Lock()
	defer s.m.Unlock()

	if s.level < level {
		return &NopCloser{io.Discard}
	}

	reader, writer := io.Pipe()
	go func() {
		sa := scanner.NewScanner(reader)
		for sa.Scan() {
			if raw {
				s.WriteString(level, sa.Text()+"\n")
			} else {
				s.Print(level, sa.Text())
			}
		}
	}()

	return writer
}

func (s *StreamLogger) WriteString(level logrus.Level, message string) {
	s.m.Lock()