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 2020/06/02 00:59:35 UTC
[pulsar] branch master updated (48ea06c -> 9cdf3fc)
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 48ea06c Allow to grant permissions when the authorization is disabled (#7074)
add 9cdf3fc [PIP-39] Introduce system topic and topic policies service (#4955)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 7 +
conf/standalone.conf | 7 +
.../apache/pulsar/broker/ServiceConfiguration.java | 11 +
.../org/apache/pulsar/broker/PulsarService.java | 14 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 35 ++-
.../pulsar/broker/namespace/NamespaceService.java | 2 +-
.../pulsar/broker/service/BrokerService.java | 39 +--
.../broker/service/BrokerServiceException.java | 6 +
.../SystemTopicBasedTopicPoliciesService.java | 333 +++++++++++++++++++++
.../org/apache/pulsar/broker/service/Topic.java | 4 +
.../broker/service/TopicPoliciesService.java | 110 +++++++
.../broker/service/persistent/PersistentTopic.java | 36 ++-
.../broker/service/persistent/SystemTopic.java | 38 +--
.../NamespaceEventsSystemTopicFactory.java | 58 ++++
.../pulsar/broker/systopic/SystemTopicClient.java | 175 +++++++++++
.../broker/systopic/SystemTopicClientBase.java | 117 ++++++++
.../systopic/TopicPoliciesSystemTopicClient.java | 166 ++++++++++
.../apache/pulsar/broker/admin/AdminApiTest.java | 10 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 2 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 12 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 6 +-
.../AntiAffinityNamespaceGroupTest.java | 2 +-
.../namespace/NamespaceOwnershipListenerTests.java | 2 +-
.../pulsar/broker/service/BrokerServiceTest.java | 4 +-
.../broker/service/PersistentTopicE2ETest.java | 2 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 188 ++++++++++++
.../TopicPoliciesServiceDisableTest.java} | 37 +--
.../pulsar/broker/stats/PrometheusMetricsTest.java | 2 +-
.../NamespaceEventsSystemTopicServiceTest.java | 118 ++++++++
.../websocket/proxy/ProxyPublishConsumeTest.java | 2 +-
.../apache/pulsar/common/events/ActionType.java | 11 +-
.../EventType.java} | 10 +-
.../pulsar/common/events/EventsTopicNames.java | 14 +-
.../PulsarEvent.java} | 13 +-
.../TopicPoliciesEvent.java} | 16 +-
.../apache/pulsar/common/events}/package-info.java | 2 +-
.../pulsar/common/policies/data/Policies.java | 6 +-
.../pulsar/common/policies/data/TopicPolicies.java | 80 +++++
38 files changed, 1564 insertions(+), 133 deletions(-)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicPoliciesService.java
copy pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/EventImpl.java => pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java (52%)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicFactory.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClientBase.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesServiceTest.java
copy pulsar-broker/src/test/java/org/apache/pulsar/broker/{namespace/NamespaceCreateBundlesTest.java => service/TopicPoliciesServiceDisableTest.java} (55%)
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java
copy pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sink.java => pulsar-common/src/main/java/org/apache/pulsar/common/events/ActionType.java (85%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{policies/data/PersistentTopicStats.java => events/EventType.java} (84%)
copy pulsar-io/core/src/main/java/org/apache/pulsar/io/core/annotations/IOType.java => pulsar-common/src/main/java/org/apache/pulsar/common/events/EventsTopicNames.java (77%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{protocol/schema/LongSchemaVersionResponse.java => events/PulsarEvent.java} (82%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{protocol/schema/IsCompatibilityResponse.java => events/TopicPoliciesEvent.java} (76%)
copy {pulsar-io/file/src/main/java/org/apache/pulsar/io/file => pulsar-common/src/main/java/org/apache/pulsar/common/events}/package-info.java (95%)
create mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java