This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from ce99a96bb5b [fix][txn]Handle exceptions in the transaction pending ack
init (#21274)
new 9b247d9510f [improve] [broker] Servlet support response compression
(#21667)
new 7ad7dedc0f7 [improve][test] Replace usage of curl in Java test and fix
stream leaks (#22463)
new 02a8e4586ca [improve][broker] Improve Gzip compression, allow
excluding specific paths or disabling it (#22370)
new bfa4d75e8bc [fix][broker] Optimize /metrics, fix unbounded request
queue issue and fix race conditions in metricsBufferResponse mode (#22494)
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
conf/proxy.conf | 6 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 13 +
.../PrometheusMetricsGeneratorUtils.java | 2 +-
.../stats/prometheus/PrometheusMetricsServlet.java | 149 +++++++---
.../apache/pulsar/broker/web/GzipHandlerUtil.java | 48 +++
.../org/apache/pulsar/broker/stats/TimeWindow.java | 94 ------
.../org/apache/pulsar/broker/stats/WindowWrap.java | 56 ----
.../broker/stats/prometheus/MetricsExports.java | 68 +++++
.../stats/prometheus/PrometheusMetricStreams.java | 2 +-
.../prometheus/PrometheusMetricsGenerator.java | 328 ++++++++++++---------
.../prometheus/PulsarPrometheusMetricsServlet.java | 140 ++++++++-
.../pulsar/broker/stats/prometheus/TopicStats.java | 12 +-
.../org/apache/pulsar/broker/web/WebService.java | 18 +-
.../apache/pulsar/PrometheusMetricsTestUtil.java | 84 ++++++
.../persistent/BucketDelayedDeliveryTest.java | 6 +-
.../service/persistent/PersistentTopicTest.java | 4 +-
.../broker/service/schema/SchemaServiceTest.java | 4 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 4 +-
.../broker/stats/MetadataStoreStatsTest.java | 6 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 114 +++----
.../pulsar/broker/stats/SubscriptionStatsTest.java | 4 +-
.../apache/pulsar/broker/stats/TimeWindowTest.java | 83 ------
.../broker/stats/TransactionMetricsTest.java | 18 +-
.../buffer/TransactionBufferClientTest.java | 4 +-
.../pendingack/PendingAckPersistentTest.java | 4 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 73 ++++-
.../pulsar/common/util/SimpleTextOutputStream.java | 16 +-
.../pulsar/proxy/server/AdminProxyHandler.java | 1 +
.../pulsar/proxy/server/ProxyConfiguration.java | 6 +
.../apache/pulsar/proxy/server/ProxyService.java | 3 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 40 ++-
31 files changed, 877 insertions(+), 533 deletions(-)
create mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/GzipHandlerUtil.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/TimeWindow.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/WindowWrap.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/MetricsExports.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/PrometheusMetricsTestUtil.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/TimeWindowTest.java
