(b *testing.B)
| 539 | } |
| 540 | |
| 541 | func BenchmarkPrefixQueueEnqueue(b *testing.B) { |
| 542 | // Open test database |
| 543 | file := fmt.Sprintf("test_db_%d", time.Now().UnixNano()) |
| 544 | pq, err := OpenPrefixQueue(file) |
| 545 | if err != nil { |
| 546 | b.Error(err) |
| 547 | } |
| 548 | defer pq.Drop() |
| 549 | |
| 550 | b.ResetTimer() |
| 551 | b.ReportAllocs() |
| 552 | |
| 553 | for n := 0; n < b.N; n++ { |
| 554 | _, _ = pq.Enqueue([]byte("prefix"), []byte("value")) |
| 555 | } |
| 556 | } |
| 557 | |
| 558 | func BenchmarkPrefixQueueDequeue(b *testing.B) { |
| 559 | // Open test database |
nothing calls this directly
no test coverage detected