Construct a QueueManager.
Optionaloptions: QueueManagerOptions = {}Configuration options.
Queue manager configuration.
OptionalbatchSize?: numberOptionaldropPolicy?: DropPolicyOptionalhighWaterMark?: numberOptionallowWaterMark?: numberOptionalmaxSize?: numberOptionalmetricsEnabled?: booleanOptionalonDrop?: (entries: LogEntry[], reason: string) => voidOptionalpriorityFn?: (entry: LogEntry) => numberClear the queue and record dropped entries.
Dequeue entries for processing.
Optionalcount: numberMaximum number of entries to dequeue (defaults to batchSize).
Dequeued entries in FIFO order.
Add a log entry to the queue.
The log entry to enqueue.
True if enqueued; false if dropped due to policy.
Add multiple log entries to the queue.
Entries to enqueue.
Number of entries successfully enqueued.
Flush and return all queued entries without processing.
All entries currently in the queue.
Whether the queue has no items.
Whether the queue has reached its maximum capacity.
Whether the queue is currently paused.
Pause queue processing (does not clear queued items).
Peek at the next entries without removing them.
Optionalcount: number = 10Number of entries to preview.
The next entries up to the specified count.
Resume processing if paused.
Set the async processor that will receive dequeued batches.
Async handler for a batch of entries.
Current number of items in the queue.
Queue manager for handling log backpressure.