This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch library-batch-queue
in repository https://gitbox.apache.org/repos/asf/skywalking.git
from 0df6788208 Fix javadoc errors by escaping > characters in comments
add 7abc9af4ef Add throughput-weighted drain rebalancing for L1 and L2
queues
No new revisions were added by this update.
Summary of changes:
docs/en/changes/changes.md | 2 +
.../analysis/worker/MetricsAggregateWorker.java | 2 +
.../worker/MetricsPersistentMinWorker.java | 2 +
.../server-library/library-batch-queue/CLAUDE.md | 49 +-
.../server-library/library-batch-queue/DESIGN.md | 259 ----------
.../library/batchqueue/BatchQueueConfig.java | 29 +-
.../server/library/batchqueue/DrainBalancer.java | 56 +++
.../batchqueue/ThroughputWeightedBalancer.java | 102 ++++
.../library/batchqueue/BatchQueueBenchmark.java | 154 ++++--
.../server/library/batchqueue/BatchQueueTest.java | 136 +++++
.../library/batchqueue/RebalanceBenchmark.java | 553 +++++++++++++++++++++
11 files changed, 1044 insertions(+), 300 deletions(-)
delete mode 100644 oap-server/server-library/library-batch-queue/DESIGN.md
create mode 100644
oap-server/server-library/library-batch-queue/src/main/java/org/apache/skywalking/oap/server/library/batchqueue/DrainBalancer.java
create mode 100644
oap-server/server-library/library-batch-queue/src/main/java/org/apache/skywalking/oap/server/library/batchqueue/ThroughputWeightedBalancer.java
create mode 100644
oap-server/server-library/library-batch-queue/src/test/java/org/apache/skywalking/oap/server/library/batchqueue/RebalanceBenchmark.java
