You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2023/04/12 01:23:42 UTC
[pulsar] branch master updated (075b6259937 -> 6514cddee5e)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 075b6259937 [fix][proxy] Refresh auth data if ProxyLookupRequests (#20067)
add 6514cddee5e [improve][broker] PIP-192: Redirect the request to current load manager (#20058)
No new revisions were added by this update.
Summary of changes:
.../broker/loadbalance/LeaderElectionService.java | 9 +-
.../pulsar/broker/loadbalance/NoopLoadManager.java | 1 +
.../loadbalance/extensions/BrokerRegistryImpl.java | 15 +--
.../extensions/ExtensibleLoadManagerImpl.java | 6 +-
.../extensions/data/BrokerLookupData.java | 12 +++
...lter.java => BrokerLoadManagerClassFilter.java} | 36 +++----
.../extensions/manager/RedirectManager.java | 116 +++++++++++++++++++++
.../BrokerLoadManagerClassFilter.java} | 40 +++----
.../loadbalance/impl/ModularLoadManagerImpl.java | 2 +
.../loadbalance/impl/SimpleLoadManagerImpl.java | 2 +
.../pulsar/broker/namespace/NamespaceService.java | 57 +++++++---
.../loadbalance/extensions/BrokerRegistryTest.java | 11 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 95 ++++++++++++++---
.../extensions/data/BrokerLookupDataTest.java | 4 +-
.../extensions/filter/BrokerFilterTestBase.java | 8 +-
.../filter/BrokerIsolationPoliciesFilterTest.java | 4 +-
....java => BrokerLoadManagerClassFilterTest.java} | 51 +++++----
.../extensions/scheduler/TransferShedderTest.java | 3 +-
.../impl/BrokerLoadManagerClassFilterTest.java | 73 +++++++++++++
.../data/loadbalancer/ServiceLookupData.java | 4 +
.../policies/data/loadbalancer/LoadReport.java | 20 ++++
.../data/loadbalancer/LocalBrokerData.java | 16 +++
22 files changed, 470 insertions(+), 115 deletions(-)
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/{AntiAffinityGroupPolicyFilter.java => BrokerLoadManagerClassFilter.java} (65%)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/RedirectManager.java
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/{LoadSheddingStrategy.java => impl/BrokerLoadManagerClassFilter.java} (51%)
copy pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/filter/{BrokerMaxTopicCountFilterTest.java => BrokerLoadManagerClassFilterTest.java} (50%)
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/BrokerLoadManagerClassFilterTest.java