fix:修复测试错误

Author: whki

window/performance_test.go

@@ -44,14 +44,14 @@ func TestTumblingWindowPerformance(t *testing.T) {
 
 			t.Logf("缓冲区大小: %d", bufferSize)
 			t.Logf("处理时间: %v", elapsed)
-			t.Logf("发送成功: %d", stats["sent_count"])
-			t.Logf("丢弃数量: %d", stats["dropped_count"])
-			t.Logf("缓冲区利用率: %d/%d", stats["buffer_used"], stats["buffer_size"])
+			t.Logf("发送成功: %d", stats["sentCount"])
+			t.Logf("丢弃数量: %d", stats["droppedCount"])
+			t.Logf("缓冲区利用率: %d/%d", stats["bufferUsed"], stats["bufferSize"])
 
 			// 验证没有严重的数据丢失
 			if bufferSize >= 1000 {
-				if stats["dropped_count"] > int64(dataCount/10) { // 允许最多10%的丢失
-					t.Errorf("丢失数据过多: %d (总数: %d)", stats["dropped_count"], dataCount)
+				if stats["droppedCount"] > int64(dataCount/10) { // 允许最多10%的丢失
+					t.Errorf("丢失数据过多: %d (总数: %d)", stats["droppedCount"], dataCount)
 				}
 			}
 
@@ -101,7 +101,7 @@ func BenchmarkTumblingWindowThroughput(b *testing.B) {
 
 	// 获取最终统计
 	stats := tw.GetStats()
-	b.Logf("发送成功: %d, 丢弃: %d", stats["sent_count"], stats["dropped_count"])
+	b.Logf("发送成功: %d, 丢弃: %d", stats["sentCount"], stats["droppedCount"])
 
 	tw.Stop()
 }
@@ -132,15 +132,15 @@ func TestWindowBufferOverflow(t *testing.T) {
 	time.Sleep(200 * time.Millisecond)
 
 	stats := tw.GetStats()
-	t.Logf("缓冲区溢出测试 - 发送: %d, 丢弃: %d", stats["sent_count"], stats["dropped_count"])
+	t.Logf("缓冲区溢出测试 - 发送: %d, 丢弃: %d", stats["sentCount"], stats["droppedCount"])
 
 	// 应该有数据被丢弃
-	if stats["dropped_count"] == 0 {
+	if stats["droppedCount"] == 0 {
 		t.Log("预期会有数据丢弃，但实际没有丢弃")
 	}
 
 	// 验证系统仍然运行正常（没有阻塞）
-	if stats["sent_count"] == 0 {
+	if stats["sentCount"] == 0 {
 		t.Error("应该至少发送了一些数据")
 	}
 

window/window_test.go

@@ -1029,8 +1029,8 @@ func TestWindowUnifiedConfigIntegration(t *testing.T) {
 
 		// 检查统计信息
 		stats := tw.GetStats()
-		assert.Contains(t, stats, "dropped_count")
-		assert.Contains(t, stats, "sent_count")
+		assert.Contains(t, stats, "droppedCount")
+		assert.Contains(t, stats, "sentCount")
 	})
 }
 
@@ -1369,8 +1369,8 @@ func TestTumblingWindowAdvanced(t *testing.T) {
 
 	// 检查统计信息
 	stats := tw.GetStats()
-	assert.Contains(t, stats, "sent_count")
-	assert.Contains(t, stats, "dropped_count")
+	assert.Contains(t, stats, "sentCount")
+	assert.Contains(t, stats, "droppedCount")
 
 	// 测试重置统计信息
 	tw.ResetStats()