You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/12/02 09:23:04 UTC
[pulsar] branch branch-2.7 updated (ae1eb1c -> 4764dc1)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from ae1eb1c [website] Update the format issue (#8773) (#8774)
add 4764dc1 Support HAProxy proxy protocol for broker and proxy (#8686) (#8740)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 3 +
conf/proxy.conf | 3 +
conf/standalone.conf | 3 +
distribution/server/src/assemble/LICENSE.bin.txt | 1 +
pom.xml | 6 ++
.../apache/pulsar/broker/ServiceConfiguration.java | 4 +
.../org/apache/pulsar/broker/service/Consumer.java | 10 +-
.../org/apache/pulsar/broker/service/Producer.java | 6 +-
.../broker/service/PulsarChannelInitializer.java | 4 +
.../apache/pulsar/broker/service/ServerCnx.java | 12 +++
.../apache/pulsar/broker/service/TransportCnx.java | 5 +
.../broker/service/EnableProxyProtocolTest.java | 105 ++++++++++++++++++
.../apache/pulsar/client/impl/ProducerImpl.java | 2 +-
pulsar-common/pom.xml | 5 +
.../protocol/OptionalProxyProtocolDecoder.java | 49 +++++++++
.../pulsar/common/protocol/PulsarDecoder.java | 11 ++
.../pulsar/proxy/server/DirectProxyHandler.java | 55 +++++++++-
.../pulsar/proxy/server/ProxyConfiguration.java | 5 +
.../pulsar/proxy/server/ProxyConnection.java | 14 +++
.../proxy/server/ServiceChannelInitializer.java | 5 +-
.../server/ProxyEnableHAProxyProtocolTest.java | 119 +++++++++++++++++++++
pulsar-sql/presto-distribution/LICENSE | 1 +
22 files changed, 423 insertions(+), 5 deletions(-)
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/EnableProxyProtocolTest.java
create mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java
create mode 100644 pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyEnableHAProxyProtocolTest.java