This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/github.com/docker/docker-28.0.0incompatible
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
discard b5614da9 chore(deps): bump github.com/docker/docker
add 1a0bfc91 Support snappy compression (#1406)
add d471a678 Change the pulsar_client_sending_buffers_count metric to
client level (#1408)
add 7a9a33c1 [issue #1357][producer] fix: allow multiples callbacks with
concurrent producer flushes (async publish) (#1409)
add ba6468a5 fix: handle reconnection logic for zero queue consumer (#1404)
add 43926211 Fix missing topic in dlq producer name when using RetryEnable
option (#1412)
add a5fb2fc6 chore: upgrade hamba/avro to v2.29.0 (#1414)
add 97fec8bc chore(deps): bump github.com/docker/docker
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b5614da9)
\
N -- N -- N
refs/heads/dependabot/go_modules/github.com/docker/docker-28.0.0incompatible
(97fec8bc)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 8 +-
.gitignore | 1 +
go.mod | 12 +-
go.sum | 20 ++--
pulsar/consumer_impl.go | 11 +-
pulsar/consumer_partition.go | 15 ++-
pulsar/consumer_test.go | 109 +++++++++++++++++-
pulsar/consumer_zero_queue_test.go | 122 +++++++++++++++++++++
pulsar/internal/batch_builder.go | 15 ++-
pulsar/internal/buffer.go | 23 +++-
.../internal/compression/compression_bench_test.go | 1 +
pulsar/internal/compression/compression_test.go | 1 +
pulsar/internal/compression/{zstd.go => snappy.go} | 36 ++++--
pulsar/internal/key_based_batch_builder.go | 6 +-
pulsar/internal/key_based_batch_builder_test.go | 2 +
pulsar/internal/metrics.go | 42 +++----
pulsar/producer.go | 2 +
pulsar/producer_partition.go | 30 ++---
pulsar/producer_test.go | 73 ++++++++++++
pulsaradmin/pkg/admin/subscription_test.go | 2 +-
20 files changed, 441 insertions(+), 90 deletions(-)
copy pulsar/internal/compression/{zstd.go => snappy.go} (57%)
