feat: optimize qos queue trimming without `heap.Init()` (`O(n*log(n)`)

xmidt-org / xmidt-agent

The client agent for the Xmidt service.

Apache License 2.0

2 stars 2 forks source link

Closed denopink closed 3 months ago

denopink commented 5 months ago

100% test cover for internal/wrphandlers/qos
optimize priorityQueue.trim() to remove messages with the lowest qos by leveraging two priority queues (1 prioritizing the highest QOS and the other prioritizing the lowest QOS)
avoid the use of heap.Init() O(n)
priorityQueue.trim() is O(n*log(n))