You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/05/26 08:22:21 UTC
[pulsar] branch master updated (6ab493c -> 3b504d0)
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 6ab493c Fix NPE when filtering read entries (#10704)
add 3b504d0 [Transactionn] Transaction admin api getTransactionBufferStatus and getPendingAckStatus (#10650)
No new revisions were added by this update.
Summary of changes:
.../pulsar/broker/admin/impl/TransactionsBase.java | 99 ++++++++++++++++++----
.../pulsar/broker/admin/v3/Transactions.java | 63 +++++++++++---
.../service/persistent/PersistentSubscription.java | 5 ++
.../broker/service/persistent/PersistentTopic.java | 10 +++
.../TransactionCoordinatorAggregator.java | 3 +-
.../transaction/buffer/TransactionBuffer.java | 7 ++
.../buffer/impl/InMemTransactionBuffer.java | 6 ++
.../buffer/impl/TopicTransactionBuffer.java | 13 +++
.../buffer/impl/TransactionBufferDisable.java | 6 ++
.../transaction/pendingack/PendingAckHandle.java | 8 ++
.../pendingack/impl/PendingAckHandleDisabled.java | 6 ++
.../pendingack/impl/PendingAckHandleImpl.java | 8 ++
.../broker/admin/v3/AdminApiTransactionTest.java | 89 +++++++++++++++----
.../apache/pulsar/client/admin/Transactions.java | 35 ++++++--
.../client/admin/internal/TransactionsImpl.java | 78 +++++++++++++----
.../pulsar/admin/cli/PulsarAdminToolTest.java | 14 ++-
.../apache/pulsar/admin/cli/CmdTransactions.java | 41 +++++++--
...eOperation.java => TransactionBufferStats.java} | 26 ++----
...tatus.java => TransactionCoordinatorStats.java} | 4 +-
...ration.java => TransactionPendingAckStats.java} | 11 +--
.../coordinator/TransactionMetadataStore.java | 12 +--
.../impl/InMemTransactionMetadataStore.java | 6 +-
.../impl/MLTransactionMetadataStore.java | 16 ++--
23 files changed, 436 insertions(+), 130 deletions(-)
copy pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{NamespaceOperation.java => TransactionBufferStats.java} (73%)
rename pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{TransactionCoordinatorStatus.java => TransactionCoordinatorStats.java} (93%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{PolicyOperation.java => TransactionPendingAckStats.java} (88%)