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