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 2021/05/21 03:58:22 UTC
[pulsar] branch master updated (5410d9c -> 7814117)
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 5410d9c When managedLedgerNewEntriesCheckDelayInMillis=0, avoid the context switch (#10660)
add 7814117 [Transaction] Transaction coordinator metrics. (#9706)
No new revisions were added by this update.
Summary of changes:
.../broker/TransactionMetadataStoreService.java | 33 ++--
.../apache/pulsar/broker/service/PulsarStats.java | 2 +
.../apache/pulsar/broker/service/ServerCnx.java | 2 +-
... => AggregatedTransactionCoordinatorStats.java} | 26 +--
.../prometheus/PrometheusMetricsGenerator.java | 4 +
.../TransactionCoordinatorAggregator.java | 110 +++++++++++++
.../recover/TransactionRecoverTrackerImpl.java | 4 +-
.../TransactionMetadataStoreServiceTest.java | 4 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 2 +-
.../broker/stats/TransactionMetricsTest.java | 180 +++++++++++++++++++++
.../coordinator/TransactionMetadataStore.java | 10 +-
.../pulsar/transaction/coordinator/TxnMeta.java | 14 ++
.../impl/InMemTransactionMetadataStore.java | 31 +++-
.../impl/MLTransactionMetadataStore.java | 55 ++++++-
.../impl/TransactionMetadataStoreStats.java | 61 +++++++
.../transaction/coordinator/impl/TxnMetaImpl.java | 16 +-
.../MLTransactionMetadataStoreTest.java | 30 ++--
.../TransactionMetadataStoreProviderTest.java | 10 +-
18 files changed, 531 insertions(+), 63 deletions(-)
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/{AggregatedConsumerStats.java => AggregatedTransactionCoordinatorStats.java} (64%)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TransactionCoordinatorAggregator.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/TransactionMetricsTest.java
create mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TransactionMetadataStoreStats.java