(src uuid.UUID)
| 343 | } |
| 344 | |
| 345 | func (l *LogSender) Flush(src uuid.UUID) { |
| 346 | l.L.Lock() |
| 347 | defer l.L.Unlock() |
| 348 | defer l.Broadcast() |
| 349 | q, ok := l.queues[src] |
| 350 | if ok { |
| 351 | q.flushRequested = true |
| 352 | } |
| 353 | // queue might not exist because it's already been flushed and removed from |
| 354 | // the map. |
| 355 | } |
| 356 | |
| 357 | var ErrLogLimitExceeded = xerrors.New("Log limit exceeded") |
| 358 |