testbench

func RunTimedTest ¶

func RunTimedTest[T any, Q queue.QueueValidationInterface[T]](
	q Q,
	cfg Config,
	testDuration time.Duration,
	valueGenerator func(int) T,
) (producedCount int64, consumedCount int64, elapsed time.Duration)

RunTimedTest spawns producers and consumers that run for the specified duration, measuring how many messages are actually enqueued/dequeued in that window. Once the context expires, producers stop and consumers drain any remaining messages in the queue. Returns the total messages enqueued, total consumed, and the actual elapsed time.