This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from dbcaa98 maxTopicsPerNamespace check should exclude system topic.
(#10850)
add b83ea98 [PIP-82] [pulsar-broker] Add resource-group configuration
listener. (#10657)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/broker/PulsarService.java | 8 +-
.../pulsar/broker/resourcegroup/ResourceGroup.java | 26 +-
.../resourcegroup/ResourceGroupConfigInfo.java | 36 ---
.../resourcegroup/ResourceGroupConfigListener.java | 159 ++++++++++++
.../ResourceGroupNamespaceConfigListener.java | 171 +++++++++++++
.../broker/resourcegroup/ResourceGroupService.java | 73 ++++--
...ava => ResourceUsageTopicTransportManager.java} | 47 ++--
.../ResourceUsageTransportManager.java | 279 +++------------------
.../ResourceGroupConfigListenerTest.java | 178 +++++++++++++
.../resourcegroup/ResourceGroupServiceTest.java | 81 +++---
.../ResourceGroupUsageAggregationTest.java | 35 +--
.../ResourceUsageTransportManagerTest.java | 15 +-
12 files changed, 709 insertions(+), 399 deletions(-)
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupConfigInfo.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupConfigListener.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupNamespaceConfigListener.java
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/{ResourceUsageTransportManager.java
=> ResourceUsageTopicTransportManager.java} (87%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupConfigListenerTest.java
