diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2025-10-17 22:11:50 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-10-17 22:11:50 -0700 |
| commit | 97f30287821e1c49b816f2e4c05be46728b06a0b (patch) | |
| tree | 1169d6e45c06698fc4081b8cfc27f2d4d2e98684 /weed/mq/offset/benchmark_test.go | |
| parent | 8d63a9cf5f011baa4b86372b4f28b7179b9dc9cb (diff) | |
| download | seaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.tar.xz seaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.zip | |
Clean up logs and deprecated functions (#7339)
* less logs
* fix deprecated grpc.Dial
Diffstat (limited to 'weed/mq/offset/benchmark_test.go')
| -rw-r--r-- | weed/mq/offset/benchmark_test.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/mq/offset/benchmark_test.go b/weed/mq/offset/benchmark_test.go index d82729142..0fdacf127 100644 --- a/weed/mq/offset/benchmark_test.go +++ b/weed/mq/offset/benchmark_test.go @@ -227,7 +227,7 @@ func BenchmarkOffsetSubscription(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { subscriptionID := fmt.Sprintf("bench-sub-%d", i) - sub, err := subscriber.CreateSubscription( + _, err := subscriber.CreateSubscription( subscriptionID, "test-namespace", "test-topic", partition, @@ -238,7 +238,6 @@ func BenchmarkOffsetSubscription(b *testing.B) { b.Fatalf("Failed to create subscription: %v", err) } subscriber.CloseSubscription(subscriptionID) - _ = sub } }) @@ -338,7 +337,7 @@ func BenchmarkSMQOffsetIntegration(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { subscriptionID := fmt.Sprintf("integration-sub-%d", i) - sub, err := integration.CreateSubscription( + _, err := integration.CreateSubscription( subscriptionID, "test-namespace", "test-topic", partition, @@ -349,7 +348,6 @@ func BenchmarkSMQOffsetIntegration(b *testing.B) { b.Fatalf("Failed to create subscription: %v", err) } integration.CloseSubscription(subscriptionID) - _ = sub } }) |