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