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%)