Skip to content

Commit

Permalink
add test
Browse files Browse the repository at this point in the history
  • Loading branch information
sharkpc138 committed Dec 11, 2024
1 parent 01f6c5b commit 979805d
Showing 1 changed file with 29 additions and 0 deletions.
29 changes: 29 additions & 0 deletions pkg/lobster/store/writer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -220,3 +220,32 @@ func checkLogOrderInBuffer(buffer *writeBuffer, t *testing.T) {
prevTs = ts
}
}

func TestWriteBufferInsertOutOfOrderFrontBufferStatus(t *testing.T) {
testCount := 10
expectedLogMsg := "out-of-order start test"
buffer := emptyWriteBuffer()
outOfOrderTsFront := time.Now().Add(-time.Minute)
outOfOrderTsRear := time.Time{}

for i := 0; i < testCount; i++ {
ts := time.Now()
outOfOrderTsRear = ts
buffer.write(ts, fmt.Sprintf("%s test\n", ts.Format(time.RFC3339Nano)))
}

checkLogOrderInBuffer(buffer, t)

buffer.write(outOfOrderTsFront, fmt.Sprintf("%s %s\n", outOfOrderTsFront.Format(time.RFC3339Nano), expectedLogMsg))
checkLogOrderInBuffer(buffer, t)

t.Logf("buffer start: %s", buffer.start.Format(time.RFC3339Nano))
t.Logf("buffer end: %s", buffer.end.Format(time.RFC3339Nano))

if !buffer.start.Equal(outOfOrderTsFront) {
t.FailNow()
}
if !buffer.end.Equal(outOfOrderTsRear) {
t.FailNow()
}
}

0 comments on commit 979805d

Please sign in to comment.