This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 136048c If cursor is not durable, close dispatcher when all consumers
are removed from subscription (#5340)
add db15d32 Added basic metadata store API and initial ZK implementation
(#5330)
No new revisions were added by this update.
Summary of changes:
pom.xml | 1 +
.../api-java => pulsar-metadata}/pom.xml | 31 ++-
.../org/apache/pulsar/metadata/api/GetResult.java | 16 +-
.../apache/pulsar/metadata/api/MetadataStore.java | 111 +++++++++
.../pulsar/metadata/api/MetadataStoreConfig.java | 23 +-
.../metadata/api/MetadataStoreException.java | 36 +--
.../pulsar/metadata/api/MetadataStoreFactory.java | 33 +--
.../java/org/apache/pulsar/metadata/api/Stat.java | 22 +-
.../metadata/impl/zookeeper/ZKMetadataStore.java | 251 +++++++++++++++++++++
.../apache/pulsar/metadata/MetadataStoreTest.java | 250 ++++++++++++++++++++
.../org/apache/pulsar/metadata/TestZKServer.java | 119 ++++++++++
11 files changed, 815 insertions(+), 78 deletions(-)
copy {pulsar-functions/api-java => pulsar-metadata}/pom.xml (67%)
copy
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionCoordinatorID.java
=> pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/GetResult.java
(73%)
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStore.java
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreConfig.java
(63%)
copy
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/PulsarServerException.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreException.java
(62%)
copy pulsar-client/src/main/java/org/apache/pulsar/client/util/MathUtils.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreFactory.java
(53%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/protocol/ProtocolHandlerMetadata.java
=> pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/Stat.java (71%)
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/zookeeper/ZKMetadataStore.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataStoreTest.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/TestZKServer.java
