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 2019/12/09 08:28:24 UTC
[pulsar] branch master updated (9aaf631 -> 5504dc6)
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 9aaf631 Add github actions ci workflow (#5642)
add 5504dc6 [transaction-coordinator] Implementation of transaction coordinator client. (#5680)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/broker/PulsarService.java | 14 +-
.../broker/TransactionMetadataStoreService.java | 85 +++-
.../broker/service/BrokerServiceException.java | 5 +
.../apache/pulsar/broker/service/ServerCnx.java | 84 +++-
.../apache/pulsar/broker/SLAMonitoringTest.java | 2 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 4 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 4 +-
.../TransactionCoordinatorAssignTest.java | 82 ----
.../TransactionCoordinatorClientTest.java | 63 +++
.../TransactionMetaStoreAssignmentTest.java | 73 ++++
.../coordinator/TransactionMetaStoreTestBase.java | 102 +++++
pulsar-client-api/pom.xml | 17 +-
.../transaction/TransactionCoordinatorClient.java | 162 ++++++++
.../TransactionCoordinatorClientException.java | 121 ++++++
pulsar-client-cpp/include/pulsar/Result.h | 2 +
pulsar-client-cpp/lib/ClientConnection.cc | 6 +
pulsar-client-cpp/lib/Result.cc | 6 +
.../org/apache/pulsar/client/impl/ClientCnx.java | 42 +-
.../client/impl/TransactionMetaStoreHandler.java | 433 +++++++++++++++++++++
...torClient.java => TransactionBufferClient.java} | 4 +-
...tImpl.java => TransactionBufferClientImpl.java} | 6 +-
.../TransactionCoordinatorClientImpl.java | 201 +++++++++-
.../apache/pulsar/common/api/proto/PulsarApi.java | 63 +++
.../apache/pulsar/common/protocol/Commands.java | 33 +-
.../pulsar/common/protocol/PulsarDecoder.java | 8 +-
pulsar-common/src/main/proto/PulsarApi.proto | 4 +
pulsar-sql/presto-distribution/LICENSE | 1 +
.../pulsar/transaction/coordinator/TxnMeta.java | 2 +-
.../exceptions/CoordinatorException.java | 46 ++-
.../exceptions/InvalidTxnStatusException.java | 44 ---
.../exceptions/TransactionNotFoundException.java | 39 --
.../impl/InMemTransactionMetadataStore.java | 4 +-
.../transaction/coordinator/impl/TxnMetaImpl.java | 7 +-
.../TransactionMetadataStoreProviderTest.java | 5 +-
src/check-binary-license | 2 +-
35 files changed, 1529 insertions(+), 247 deletions(-)
delete mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionCoordinatorAssignTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionCoordinatorClientTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreAssignmentTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java
create mode 100644 pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClient.java
create mode 100644 pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java
create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java
rename pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/{TransactionCoordinatorClient.java => TransactionBufferClient.java} (95%)
copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/{TransactionCoordinatorClientImpl.java => TransactionBufferClientImpl.java} (90%)
delete mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/InvalidTxnStatusException.java
delete mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/TransactionNotFoundException.java