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

Posted to commits@pulsar.apache.org by mm...@apache.org on 2020/12/10 18:58:38 UTC

[pulsar-client-go] branch master updated (9fe66ed -> 21541d6)

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

mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.


    from 9fe66ed  Read the clock fewer times during message routing (#408)
     add 21541d6  Attach topic and custom labels to Prometheus metrics (#410)

No new revisions were added by this update.

Summary of changes:
 oauth2/cache/cache.go                  |   2 +-
 pulsar/client.go                       |   3 +
 pulsar/client_impl.go                  |  17 +-
 pulsar/consumer_impl.go                |  37 +---
 pulsar/consumer_multitopic.go          |   2 -
 pulsar/consumer_partition.go           |  77 ++------
 pulsar/consumer_partition_test.go      |   3 +
 pulsar/consumer_regex.go               |   2 -
 pulsar/internal/connection.go          |  41 +---
 pulsar/internal/connection_pool.go     |   6 +-
 pulsar/internal/lookup_service.go      |  16 +-
 pulsar/internal/lookup_service_test.go |  16 +-
 pulsar/internal/metrics.go             | 344 ++++++++++++++++++++++++++++++++-
 pulsar/internal/rpc_client.go          |  21 +-
 pulsar/internal/topic_name.go          |   2 +
 pulsar/internal/topic_name_test.go     |   7 +
 pulsar/metrics.go                      |  24 ---
 pulsar/producer_impl.go                |  35 +---
 pulsar/producer_partition.go           |  84 ++------
 pulsar/reader_impl.go                  |  24 +--
 20 files changed, 454 insertions(+), 309 deletions(-)
 delete mode 100644 pulsar/metrics.go