Update documentation for RingLogger's ring buffer
Signed-off-by: Nick Neisen <nwneisen@gmail.com> Upstream-commit: 3521d534e5c9338ae5605d1228554862e922a8a9 Component: engine
This commit is contained in:
@@ -150,7 +150,7 @@ func newRing(maxBytes int64) *messageRing {
|
||||
}
|
||||
|
||||
// Enqueue adds a message to the buffer queue
|
||||
// If the message is too big for the buffer it drops the oldest messages to make room
|
||||
// If the message is too big for the buffer it drops the new message.
|
||||
// If there are no messages in the queue and the message is still too big, it adds the message anyway.
|
||||
func (r *messageRing) Enqueue(m *Message) error {
|
||||
mSize := int64(len(m.Line))
|
||||
|
||||
@@ -58,7 +58,7 @@ func TestRingCap(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
// should have messages in the queue for "5" to "10"
|
||||
// should have messages in the queue for "0" to "4"
|
||||
for i := 0; i < 5; i++ {
|
||||
m, err := r.Dequeue()
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user