We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 421a5cb commit 5672b80Copy full SHA for 5672b80
1 file changed
stats/totalevent_test.go
@@ -10,7 +10,7 @@ import (
10
)
11
12
func TestFlushTotalEventStat(t *testing.T) {
13
- // Arrange
+ // setup
14
eventCh := make(chan int32, 10)
15
producedCh := make(chan *pb.TotalEventCountMessage, 10) // <- initialize channel
16
mockKP := &mockKafkaProducer{producedCh: producedCh}
@@ -41,7 +41,7 @@ func TestFlushTotalEventStat(t *testing.T) {
41
}
42
43
44
-// Optional: add a timeout test to ensure aggregation resets
+// add a timeout test to ensure aggregation resets
45
func TestFlushResetsAfterPublish(t *testing.T) {
46
47
producedCh := make(chan *pb.TotalEventCountMessage, 10)
0 commit comments