You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by he...@apache.org on 2024/06/15 00:34:51 UTC

(pulsar) branch master updated (f1228177727 -> f83dbe9cf77)

This is an automated email from the ASF dual-hosted git repository.

heesung pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from f1228177727 [fix] [broker] Fix typo in PersistentTopicsBase (#22904)
     add f83dbe9cf77 [feat][broker] PIP-264: Add OpenTelemetry producer metrics (#22882)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/broker/PulsarService.java    |  7 ++
 .../org/apache/pulsar/broker/service/Producer.java | 86 +++++++++++---------
 .../broker/stats/OpenTelemetryProducerStats.java   | 95 ++++++++++++++++++++++
 ...st.java => OpenTelemetryProducerStatsTest.java} | 59 +++-----------
 .../pulsar/client/api/BrokerServiceLookupTest.java |  1 +
 .../pulsar/client/api/NonPersistentTopicTest.java  | 31 ++++++-
 .../stats/NonPersistentPublisherStatsImpl.java     | 20 +++++
 .../policies/data/stats/PublisherStatsImpl.java    | 39 +++++++++
 .../java/org/apache/pulsar/common/stats/Rate.java  |  7 ++
 .../opentelemetry/OpenTelemetryAttributes.java     | 15 ++++
 10 files changed, 273 insertions(+), 87 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryProducerStats.java
 copy pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/{OpenTelemetryConsumerStatsTest.java => OpenTelemetryProducerStatsTest.java} (50%)