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/01/19 18:51:44 UTC
[pulsar] branch master updated (63acd20 -> 29b0f08)
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 63acd20 [flaky test] Fix unit tests that occasionally fail (#9226)
add 29b0f08 PIP-45: Implement CoordinationService on top of MetadataStore (#9221)
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 2 +-
.../metadata/{cache => api}/MetadataCache.java | 2 +-
.../apache/pulsar/metadata/api/MetadataStore.java | 1 -
.../metadata/api/MetadataStoreException.java | 53 +++-
.../pulsar/metadata/api/MetadataStoreFactory.java | 2 +-
.../java/org/apache/pulsar/metadata/api/Stat.java | 6 +
.../api/coordination/CoordinationService.java | 57 +++++
.../metadata/api/coordination/LeaderElection.java | 71 ++++++
.../LeaderElectionState.java} | 21 +-
.../metadata/api/coordination/LockManager.java | 98 ++++++++
.../metadata/api/coordination/ResourceLock.java | 38 ++-
.../{GetResult.java => extended/CreateOption.java} | 18 +-
.../api/extended/MetadataStoreExtended.java | 74 ++++++
.../metadata/cache/impl/MetadataCacheImpl.java | 6 +-
.../coordination/impl/CoordinationServiceImpl.java | 96 ++++++++
.../coordination/impl/LeaderElectionImpl.java | 273 +++++++++++++++++++++
.../coordination/impl/LockManagerImpl.java | 145 +++++++++++
.../coordination/impl/ResourceLockImpl.java | 107 ++++++++
.../metadata/impl/AbstractMetadataStore.java | 73 +++++-
.../metadata/impl/LocalMemoryMetadataStore.java | 42 ++--
.../pulsar/metadata/impl/ZKMetadataStore.java | 47 +++-
.../org/apache/pulsar/metadata/CounterTest.java | 54 ++++
.../apache/pulsar/metadata/LeaderElectionTest.java | 175 +++++++++++++
.../apache/pulsar/metadata/LockManagerTest.java | 151 ++++++++++++
.../apache/pulsar/metadata/MetadataCacheTest.java | 2 +-
.../apache/pulsar/metadata/MetadataStoreTest.java | 7 +-
26 files changed, 1533 insertions(+), 88 deletions(-)
rename pulsar-metadata/src/main/java/org/apache/pulsar/metadata/{cache => api}/MetadataCache.java (99%)
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/coordination/CoordinationService.java
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/coordination/LeaderElection.java
copy pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/{Notification.java => coordination/LeaderElectionState.java} (75%)
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/coordination/LockManager.java
copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/SendCallback.java => pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/coordination/ResourceLock.java (53%)
copy pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/{GetResult.java => extended/CreateOption.java} (72%)
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/extended/MetadataStoreExtended.java
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/CoordinationServiceImpl.java
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LeaderElectionImpl.java
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LockManagerImpl.java
create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/CounterTest.java
create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/LeaderElectionTest.java
create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/LockManagerTest.java