You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2019/11/06 03:41:49 UTC
[pulsar] branch master updated (bafde2c -> e0b36f9)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from bafde2c Fix Test Assertion retry (#5544)
add e0b36f9 [Transaction coordinator]Add transaction metadata store service (#5504)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 3 +-
conf/standalone.conf | 5 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 7 ++
pulsar-broker/pom.xml | 11 ++
.../java/org/apache/pulsar/PulsarStandalone.java | 3 +
.../org/apache/pulsar/broker/PulsarService.java | 15 +++
.../broker/TransactionMetadataStoreService.java | 119 +++++++++++++++++++++
.../TransactionMetadataStoreServiceTest.java | 115 ++++++++++++++++++++
pulsar-transaction/coordinator/pom.xml | 6 ++
.../coordinator/TransactionCoordinatorID.java | 4 +
.../coordinator/TransactionMetadataStore.java | 5 +
.../TransactionMetadataStoreProvider.java | 5 +-
.../exceptions/CoordinatorException.java | 24 +++++
.../impl/InMemTransactionMetadataStore.java | 6 ++
.../InMemTransactionMetadataStoreProvider.java | 7 +-
.../TransactionMetadataStoreProviderTest.java | 2 +-
16 files changed, 330 insertions(+), 7 deletions(-)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java