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