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 60161ed Fix peek message metadata broker while enable broker entry
metadata. (#9255)
add 37d778b [Transaction] Transaction timeout implementation. (#9229)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/broker/PulsarService.java | 8 +-
.../broker/TransactionMetadataStoreService.java | 32 +++++-
.../apache/pulsar/broker/service/ServerCnx.java | 3 +-
.../buffer/impl/TransactionBufferClientImpl.java | 6 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 10 +-
.../TransactionTimeoutTrackerFactoryImpl.java | 50 +++++++++
.../timeout/TransactionTimeoutTrackerImpl.java | 122 +++++++++++++++++++++
.../{buffer => timeout}/package-info.java | 2 +-
.../TransactionMetadataStoreServiceTest.java | 114 ++++++++++++++++++-
.../buffer/TransactionBufferClientTest.java | 5 +-
.../client/impl/TransactionEndToEndTest.java | 57 +++++++---
.../TransactionMetadataStoreProvider.java | 4 +-
.../coordinator/TransactionTimeoutTracker.java | 62 +++++++++++
....java => TransactionTimeoutTrackerFactory.java} | 17 +--
.../InMemTransactionMetadataStoreProvider.java | 5 +-
.../impl/MLTransactionMetadataStore.java | 11 +-
.../impl/MLTransactionMetadataStoreProvider.java | 7 +-
.../MLTransactionMetadataStoreTest.java | 37 ++++++-
.../TransactionMetadataStoreProviderTest.java | 2 +-
19 files changed, 499 insertions(+), 55 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/timeout/TransactionTimeoutTrackerFactoryImpl.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/timeout/TransactionTimeoutTrackerImpl.java
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer
=> timeout}/package-info.java (94%)
create mode 100644
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionTimeoutTracker.java
copy
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/{TransactionCoordinatorID.java
=> TransactionTimeoutTrackerFactory.java} (73%)
