You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/09/13 15:21:58 UTC
[pulsar] branch master updated (c04945e -> ca63ee6)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from c04945e Add option to customize splitter character (#5187)
add ca63ee6 PIP-41 (part-1): Introduce Protocol Handler API (#5130)
No new revisions were added by this update.
Summary of changes:
.../apache/pulsar/broker/ServiceConfiguration.java | 16 ++
.../org/apache/pulsar/broker/PulsarService.java | 32 +++-
.../pulsar/broker/loadbalance/LoadManager.java | 6 +-
.../pulsar/broker/loadbalance/NoopLoadManager.java | 1 +
.../loadbalance/impl/ModularLoadManagerImpl.java | 4 +
.../loadbalance/impl/SimpleLoadManagerImpl.java | 2 +
.../pulsar/broker/protocol/ProtocolHandler.java | 97 ++++++++++++
.../broker/protocol/ProtocolHandlerDefinition.java | 14 +-
.../protocol/ProtocolHandlerDefinitions.java | 17 +--
.../broker/protocol/ProtocolHandlerMetadata.java | 23 +--
.../broker/protocol/ProtocolHandlerUtils.java | 156 +++++++++++++++++++
.../protocol/ProtocolHandlerWithClassLoader.java | 83 +++++++++++
.../pulsar/broker/protocol/ProtocolHandlers.java | 148 ++++++++++++++++++
.../pulsar/broker/protocol}/package-info.java | 4 +-
.../pulsar/broker/service/BrokerService.java | 49 +++++-
.../broker/protocol/MockProtocolHandler.java | 45 +++---
.../broker/protocol/ProtocolHandlerUtilsTest.java | 155 +++++++++++++++++++
.../ProtocolHandlerWithClassLoaderTest.java | 70 +++++++++
.../broker/protocol/ProtocolHandlersTest.java | 166 +++++++++++++++++++++
.../policies/data/loadbalancer/LoadReport.java | 17 +++
.../data/loadbalancer/LocalBrokerData.java | 20 +++
.../data/loadbalancer/ServiceLookupData.java | 19 +++
22 files changed, 1088 insertions(+), 56 deletions(-)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandler.java
copy managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderDefinition.java => pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerDefinition.java (75%)
copy pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionCoordinatorID.java => pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerDefinitions.java (73%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/protocol/schema/IsCompatibilityResponse.java => pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerMetadata.java (72%)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtils.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerWithClassLoader.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlers.java
copy {pulsar-client-api/src/main/java/org/apache/pulsar/client/api => pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol}/package-info.java (91%)
copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/NonPersistentAcknowledgmentGroupingTracker.java => pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/MockProtocolHandler.java (52%)
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlerUtilsTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlerWithClassLoaderTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/protocol/ProtocolHandlersTest.java