Skip to main content

benchQueue

@webda/bench


Function: benchQueue()

benchQueue(harness, options?): Promise<BenchResult[]>

Defined in: packages/bench/src/suites/queue.ts:150

Benchmark a queue through the Queue API

Scenarios: send throughput, raw drain (receiveMessage + deleteMessage), consume() workers for each maxConsumers and workerParallelism, open-loop end-to-end latency and, when the harness defines redeliveryDelayMs and the profile enables it, redelivery of failed messages.

Parameters​

harness​

QueueBenchHarness

creates the queue under test

options?​

QueueBenchOptions = {}

profile, filter and reporters

Returns​

Promise<BenchResult[]>

the results