(level logrus.Level, message string)
| 483 | } |
| 484 | |
| 485 | func (s *StreamLogger) WriteString(level logrus.Level, message string) { |
| 486 | s.m.Lock() |
| 487 | defer s.m.Unlock() |
| 488 | |
| 489 | for _, s := range s.sinks { |
| 490 | s.WriteString(level, message) |
| 491 | } |
| 492 | |
| 493 | if s.level < level { |
| 494 | return |
| 495 | } |
| 496 | _, _ = s.write(level, []byte(message)) |
| 497 | } |
| 498 | |
| 499 | func (s *StreamLogger) write(level logrus.Level, message []byte) (int, error) { |
| 500 | var ( |