You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2022/02/08 20:39:03 UTC
[pulsar] branch master updated (f916e2c -> 640b4e6)
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from f916e2c support lazy init BaseMetadataStoreTest#etcdCluster (#14167)
add 640b4e6 [Proxy] Fix port exhaustion and connection issues in Pulsar Proxy (#14078)
No new revisions were added by this update.
Summary of changes:
distribution/server/src/assemble/LICENSE.bin.txt | 2 +
pom.xml | 1 +
.../ProxySaslAuthenticationTest.java | 1 +
.../pulsar/common/protocol/PulsarHandler.java | 2 +-
pulsar-proxy/pom.xml | 17 +-
.../pulsar/proxy/server/BrokerProxyValidator.java | 181 +++++++++++++++++++++
.../pulsar/proxy/server/DirectProxyHandler.java | 156 ++++++++++--------
.../pulsar/proxy/server/ProxyConfiguration.java | 39 +++++
.../pulsar/proxy/server/ProxyConnection.java | 99 +++++++++--
.../apache/pulsar/proxy/server/ProxyService.java | 17 ++
.../pulsar/proxy/server/ProxyServiceStarter.java | 2 +
.../proxy/server/ServiceChannelInitializer.java | 8 +
.../proxy/server/TargetAddressDeniedException.java | 10 +-
.../extensions/SimpleProxyExtensionTestBase.java | 1 +
.../proxy/server/AuthedAdminProxyHandlerTest.java | 1 +
.../proxy/server/BrokerProxyValidatorTest.java | 102 ++++++++++++
.../proxy/server/ProxyAdditionalServletTest.java | 1 +
.../ProxyAuthenticatedProducerConsumerTest.java | 1 +
.../proxy/server/ProxyAuthenticationTest.java | 1 +
.../pulsar/proxy/server/ProxyConnectionTest.java | 21 +--
.../server/ProxyConnectionThrottlingTest.java | 1 +
.../server/ProxyEnableHAProxyProtocolTest.java | 1 +
.../proxy/server/ProxyForwardAuthDataTest.java | 1 +
.../proxy/server/ProxyKeyStoreTlsTestWithAuth.java | 1 +
.../server/ProxyKeyStoreTlsTestWithoutAuth.java | 1 +
.../proxy/server/ProxyLookupThrottlingTest.java | 1 +
.../pulsar/proxy/server/ProxyParserTest.java | 1 +
.../proxy/server/ProxyRolesEnforcementTest.java | 1 +
.../proxy/server/ProxyServiceStarterTest.java | 5 +-
.../proxy/server/ProxyServiceTlsStarterTest.java | 15 +-
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 1 +
.../org/apache/pulsar/proxy/server/ProxyTest.java | 1 +
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 1 +
.../pulsar/proxy/server/ProxyTlsTestWithAuth.java | 1 +
.../server/ProxyWithAuthorizationNegTest.java | 1 +
.../proxy/server/ProxyWithAuthorizationTest.java | 2 +
.../server/ProxyWithJwtAuthorizationTest.java | 1 +
.../server/ProxyWithoutServiceDiscoveryTest.java | 1 +
.../SuperUserAuthedAdminProxyHandlerTest.java | 1 +
.../server/UnauthedAdminProxyHandlerTest.java | 1 +
40 files changed, 596 insertions(+), 106 deletions(-)
create mode 100644 pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/BrokerProxyValidator.java
copy pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java => pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/TargetAddressDeniedException.java (81%)
create mode 100644 pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/BrokerProxyValidatorTest.java
copy pulsar-common/src/test/java/org/apache/pulsar/common/policies/impl/MinAvailablePolicyTest.java => pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyConnectionTest.java (59%)