func()

in logger/buffered_logger.go [232:248]

• 14 lines of code
• 4 McCabe index (conditional complexity)

func (bl *bufferedLogger) sendLogMessageToDestination() error {
	msg, err := bl.buffer.Dequeue()
	// Do an early return if ring buffer is closed.
	if bl.buffer.isClosed {
		return nil
	}
	if err != nil {
		return errors.Wrap(err, "failed to read logs from buffer")
	}

	err = bl.Log(msg.Line, msg.Source, msg.Timestamp)
	if err != nil {
		return errors.Wrap(err, "failed to send logs to destination")
	}

	return nil
}