(b *testing.B)
| 589 | } |
| 590 | |
| 591 | func BenchmarkQueueEnqueue(b *testing.B) { |
| 592 | // Open test database |
| 593 | file := fmt.Sprintf("test_db_%d", time.Now().UnixNano()) |
| 594 | q, err := OpenQueue(file) |
| 595 | if err != nil { |
| 596 | b.Error(err) |
| 597 | } |
| 598 | defer q.Drop() |
| 599 | |
| 600 | b.ResetTimer() |
| 601 | b.ReportAllocs() |
| 602 | |
| 603 | for n := 0; n < b.N; n++ { |
| 604 | _, _ = q.Enqueue([]byte("value")) |
| 605 | } |
| 606 | } |
| 607 | |
| 608 | func BenchmarkQueueDequeue(b *testing.B) { |
| 609 | // Open test database |