(line string)
| 59 | } |
| 60 | |
| 61 | func (mrlb *MultiReaderLineBuffer) addLine(line string) { |
| 62 | mrlb.lock.Lock() |
| 63 | defer mrlb.lock.Unlock() |
| 64 | |
| 65 | mrlb.totalLineCount++ |
| 66 | |
| 67 | if len(mrlb.lines) >= mrlb.maxLines { |
| 68 | mrlb.lines = append(mrlb.lines[1:], line) |
| 69 | } else { |
| 70 | mrlb.lines = append(mrlb.lines, line) |
| 71 | } |
| 72 | } |
| 73 | |
| 74 | func (mrlb *MultiReaderLineBuffer) GetLines() []string { |
| 75 | mrlb.lock.Lock() |