You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/02/20 03:22:08 UTC

[pulsar] branch master updated (ec59e93 -> 1fab5aa)

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from ec59e93  Consistently pass "alwaysRun = true" to all TestNG @After* annotations (#9635)
     add 1fab5aa  [pulsar-broker] Authorization service uses metadata-store api (#9586)

No new revisions were added by this update.

Summary of changes:
 pulsar-broker-common/pom.xml                       |  6 ++
 .../authorization/PulsarAuthorizationProvider.java | 87 ++++++++--------------
 .../broker/cache/ConfigurationCacheService.java    | 18 ++++-
 .../cache/ConfigurationMetadataCacheService.java   | 78 +++++++++++++++++++
 .../pulsar/broker/resources}/BaseResources.java    |  2 +-
 .../pulsar/broker/resources}/ClusterResources.java |  3 +-
 .../resources}/DynamicConfigurationResources.java  |  3 +-
 .../broker/resources/LocalPoliciesResources.java   | 11 +--
 .../broker/resources}/NamespaceResources.java      | 19 +----
 .../pulsar/broker/resources/PulsarResources.java   | 65 ++++++++++++++++
 .../pulsar/broker/resources}/TenantResources.java  |  2 +-
 .../org/apache/pulsar/broker/PulsarService.java    |  5 +-
 .../apache/pulsar/broker/admin/AdminResource.java  | 60 +++------------
 .../pulsar/broker/admin/impl/ClustersBase.java     |  2 +-
 .../pulsar/broker/admin/impl/NamespacesBase.java   | 22 ++++--
 .../broker/admin/impl/PersistentTopicsBase.java    |  2 +-
 .../pulsar/broker/admin/impl/PulsarResources.java  | 41 ----------
 .../apache/pulsar/broker/admin/v1/Namespaces.java  |  7 +-
 .../pulsar/broker/web/PulsarWebResource.java       | 22 ++++--
 .../broker/admin/AdminApiGetLastMessageIdTest.java |  2 -
 .../org/apache/pulsar/broker/admin/AdminTest.java  | 16 ----
 .../apache/pulsar/broker/admin/NamespacesTest.java |  2 -
 .../pulsar/broker/admin/PersistentTopicsTest.java  |  4 -
 .../pulsar/client/api/BrokerServiceLookupTest.java | 15 +++-
 .../client/impl/BrokerClientIntegrationTest.java   |  2 +-
 .../websocket/proxy/ProxyAuthenticationTest.java   |  5 +-
 .../websocket/proxy/ProxyAuthorizationTest.java    |  5 +-
 .../websocket/proxy/ProxyConfigurationTest.java    |  5 +-
 .../websocket/proxy/ProxyPublishConsumeTest.java   |  5 +-
 .../proxy/ProxyPublishConsumeTlsTest.java          |  5 +-
 .../proxy/ProxyPublishConsumeWithoutZKTest.java    |  5 +-
 .../proxy/v1/V1_ProxyAuthenticationTest.java       |  5 +-
 .../discovery/service/BrokerDiscoveryProvider.java | 50 +++++--------
 .../pulsar/discovery/service/DiscoveryService.java | 34 ++++++++-
 .../discovery/service/BaseDiscoveryTestSetup.java  |  3 +
 .../discovery/service/DiscoveryServiceTest.java    |  4 +-
 .../org/apache/pulsar/functions/worker/Worker.java | 29 ++++----
 .../metadata/impl/AbstractMetadataStore.java       |  2 -
 .../metadata/impl/LocalMemoryMetadataStore.java    |  1 -
 .../apache/pulsar/metadata/MetadataStoreTest.java  |  1 -
 .../proxy/server/BrokerDiscoveryProvider.java      | 22 ++----
 .../apache/pulsar/proxy/server/ProxyService.java   | 43 ++++++++++-
 .../proxy/server/AuthedAdminProxyHandlerTest.java  |  7 +-
 .../proxy/server/ProxyAdditionalServletTest.java   |  3 +
 .../ProxyAuthenticatedProducerConsumerTest.java    |  3 +
 .../server/ProxyConnectionThrottlingTest.java      |  3 +
 .../server/ProxyEnableHAProxyProtocolTest.java     |  3 +
 .../pulsar/proxy/server/ProxyIsAHttpProxyTest.java | 21 ++++--
 .../proxy/server/ProxyKeyStoreTlsTestWithAuth.java |  3 +
 .../server/ProxyKeyStoreTlsTestWithoutAuth.java    |  3 +
 .../proxy/server/ProxyLookupThrottlingTest.java    |  3 +
 .../pulsar/proxy/server/ProxyParserTest.java       |  3 +
 .../apache/pulsar/proxy/server/ProxyStatsTest.java |  3 +
 .../org/apache/pulsar/proxy/server/ProxyTest.java  |  3 +
 .../apache/pulsar/proxy/server/ProxyTlsTest.java   |  3 +
 .../pulsar/proxy/server/ProxyTlsTestWithAuth.java  |  3 +
 .../SuperUserAuthedAdminProxyHandlerTest.java      |  7 +-
 .../server/UnauthedAdminProxyHandlerTest.java      |  7 +-
 .../apache/pulsar/websocket/WebSocketService.java  | 59 +++++++--------
 59 files changed, 508 insertions(+), 349 deletions(-)
 create mode 100644 pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationMetadataCacheService.java
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources}/BaseResources.java (99%)
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources}/ClusterResources.java (97%)
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources}/DynamicConfigurationResources.java (96%)
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantResources.java => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/LocalPoliciesResources.java (71%)
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources}/NamespaceResources.java (79%)
 create mode 100644 pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/PulsarResources.java
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources}/TenantResources.java (96%)
 delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PulsarResources.java