This is an automated email from the ASF dual-hosted git repository.
xiangying pushed a change to branch xiangying/txn/tc_client
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
from 91803b0 [feat][txn]Implement transactionCoordinatorClient Master
Issue:https://github.com/apache/pulsar-client-go/issues/932 ### Motivation
Implement transaction coordinator client. ### Modifications 1. Implement
transaction coordinator 2. implement transaction API 3. Add metric and test
add 5108332 Add error response for Ack func (#775)
add 67e2075 Revert "Fix stuck when reconnect broker (#703)" (#767)
add a8270eb fix nil pointer dereference in TopicNameWithoutPartitionPart
(#734)
add c41616b Support ack response for Go SDK (#776)
add 15136a7 Fix ack request not set requestId when enable AckWithResponse
option (#780)
add c558ddf [issue 791] allow to add at least one message on batch
builder (#792)
add b392b9c schema creation and validation functions without panicing
(#794)
add cac144a [github ci] add go 1.18 to the test matrix (#790)
add 1e2422b Fix using closed connection in consumer (#785)
add 2ae909e feat: add basic authentication (#778)
add 0f7041f [Issue 781][add consumer seek by time on partitioned topic]
(#782)
add e95cf06 [ci] update and simplify GitHub workflow (#796)
add ea6eccf feat: support multiple schema version for producer and
consumer (#611)
add 6a8e7f3 [issue #752] replace go-rate rate limiter with a buffered
channel implementation (#799)
add bd19458 [issue 814] consumer and producer reconnect failure metrics
counter (#815)
add c247619 style: fix to follow lint error (#824)
add 934c867 [oauth2] Remove oauth2 go.mod and go.sum (#802)
add 91b807d chore: rename test_helper to follow test code naming
convention (#822)
add 3d63718 Bump github.com/stretchr/testify to update gopkg.in/yaml.v3
(#813)
add a09460e [client] Add MetricsRegisterer to ClientOptions (#826)
add da24461 Add golang 1.19 in tests matrix (#832)
add 2d5f6fc ci: add makefile (#800)
add f8dc88e Make keepalive interval configurable (#838)
add 68e4317 [issue #807] dlq topic producer options (#809)
add fb8e801 [log-format] remove redundant "[]" pair in the head and tail
of log content (#831)
add 649d992 Update proto file latest (#841)
add b06e198 [bugfix] Fix wrong check eventime by default (#843)
add edd5c71 NackBackoffPolicy.Next return time.Duration (#834)
add e78dc3c Introduce doneCh for ack error (#777)
add 6a8847f Parameterize the reconnection option (#853)
add 9ecebb1 add 0.9.0 release changelog (#804)
add dd63a4c Embed Go SDK version to 0.9.0 (#854)
add fce0cb0 Add TLS transport config (#855)
add dedbdc4 read module version info from golang runtime (#856)
add c8e9195 fix typo (#857)
add a013ff0 [Issue 833] Fix the availablePermits leak that could cause
consumer stuck. (#835)
add 60856f2 Only send notifications to commits@ ML (#861)
add bea85d4 [CI] Add go test flag '-v' for more clearly CI log (#871)
add 77c7ccb [Issue 456] Support chunking for big messages. (#805)
add 0b0720a Fix marshalling time.Time{} to uint64 (#865)
add 5679f1f [Fix] Fix the dispatcher() stuck caused by availablePermitsCh
(#875)
add 4e6915d [Issue 867][CI] Fix bot cannot get the pr link (#868) (#868)
add 44b64aa [Issue 489] TLS fix for certificate that does not include IP
SANS, save hostname before switching to physical addr (#812)
add 0412f28 fix: fix the internalSend() return without
sendRequest.callback() (#880)
add d9c8b0a Fix PR template (#869)
add edfb785 feat: add BackoffPolicy to `reader` and improve test case
(#889)
add 03aabd4 Fix load tls certificate (#888)
add 39e11c7 Use constant for the data prefix (#866)
add 4ebb3c7 Add data url format to read the key file (#883)
add 0b197f7 fix: fix 879 (#881)
add 884e13e prevent consumer panic on de-serializing message if schema
not found (#886)
add 48c39ee [Issue 453] Add NewMessageID() method. (#893)
add 055b00b fix: fix 879 (#902)
add 1fe9b62 [feat] support for consumer event listener (#904)
add 504e589 Use protocolbuffers instead of gogo (#895)
add 4e24fce [build] update go version to 1.18 (#911)
add d92fb14 Default retry and dlq topic name fixed as per the doc (#891)
add 1d3499a fix: fix 923 (#924)
add cb983a7 Move out the auth package from internal (#914)
add 2377736 [Issue 183] [Feat] Support cumulative acknowledge (#903)
add 9fc96d4 Handle nil value message correctly in table-view (#930)
add 1f3747e Allow CustomProperties when sending message for retry (#916)
add 44dc85c [Issue 918] [Refactor] Remove the clearMessageQueuesCh in
partitionConsumer.dispatcher() (#921)
add cf031b8 add messageId and topic as props of DLQ message (#907)
add 3cd02b1 [feature] Support batch index ACK (#938)
add d9b18d0 Update the Cobra library to significantly reduce the
dependency tree (#943)
add b0b7849 Use pkg.go.dev badge in the readme (#947)
add 718a631 Remove go1.11 code leftovers (#946)
add fa4662c Migrate from the deprecated io/ioutil package (#942)
add c346caf Improve test script (#951)
add 93a5a76 [feat] Support Exclusive Producer access mode. (#944)
new 802bbf4 Merge remote-tracking branch 'origin/master' into
xiangying/txn/tc_client
The 1 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:
.asf.yaml | 10 +-
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
.github/workflows/bot.yml | 1 +
.github/workflows/go.yml | 26 -
.github/workflows/project.yml | 45 +-
.golangci.yml | 23 +-
CHANGELOG.md | 48 +
Dockerfile | 25 +-
docker-ci.sh => Makefile | 30 +-
README.md | 43 +-
VERSION | 2 +-
go.mod | 50 +-
go.sum | 233 +-
integration-tests/conf/.htpasswd | 1 +
integration-tests/{ => conf}/client.conf | 0
integration-tests/{ => conf}/standalone.conf | 4 +-
integration-tests/license_test.go | 6 +-
integration-tests/pb/build.sh | 4 +-
integration-tests/pb/hello.pb.go | 180 +-
integration-tests/pb/hello.proto | 2 +
oauth2/authorization_tokenretriever.go | 1 -
oauth2/authorization_tokenretriever_test.go | 14 +-
oauth2/client_credentials_provider.go | 14 +-
oauth2/client_credentials_provider_test.go | 77 +
oauth2/data_url.go | 70 +
oauth2/data_url_test.go | 58 +
oauth2/go.mod | 12 -
oauth2/go.sum | 117 -
oauth2/oidc_endpoint_provider_test.go | 4 +-
perf/perf-producer.go | 23 +-
perf/pulsar-perf-go.go | 3 +-
pulsar/{internal => }/auth/athenz.go | 4 +-
pulsar/{internal => }/auth/athenz_test.go | 8 +-
pulsar/auth/basic.go | 84 +
pulsar/auth/basic_test.go | 70 +
pulsar/{internal => }/auth/disabled.go | 0
pulsar/{internal => }/auth/oauth2.go | 0
pulsar/{internal => }/auth/oauth2_test.go | 3 +-
pulsar/{internal => }/auth/provider.go | 3 +
pulsar/{internal => }/auth/tls.go | 0
pulsar/{internal => }/auth/token.go | 4 +-
pulsar/client.go | 21 +-
pulsar/client_impl.go | 29 +-
pulsar/client_impl_test.go | 95 +-
pulsar/consumer.go | 53 +-
pulsar/consumer_impl.go | 193 +-
pulsar/consumer_multitopic.go | 57 +-
pulsar/consumer_partition.go | 833 +-
pulsar/consumer_partition_test.go | 15 +-
pulsar/consumer_regex.go | 55 +-
pulsar/consumer_test.go | 1077 +-
pulsar/crypto/default_crypto_Key_reader.go | 4 +-
pulsar/dlq_router.go | 30 +-
pulsar/helper.go | 2 +-
pulsar/{test_helper.go => helper_for_test.go} | 3 +-
pulsar/impl_message.go | 182 +-
pulsar/impl_message_test.go | 33 +-
pulsar/internal/backoff.go | 26 +-
pulsar/internal/backoff_test.go | 8 +-
pulsar/internal/batch_builder.go | 59 +-
pulsar/internal/commands.go | 60 +-
.../internal/compression/compression_bench_test.go | 8 +-
pulsar/internal/connection.go | 110 +-
pulsar/internal/connection_pool.go | 17 +-
pulsar/internal/connection_reader.go | 2 +-
pulsar/internal/http_client.go | 22 +-
pulsar/internal/http_client_go_1.11.go | 33 -
pulsar/internal/key_based_batch_builder.go | 18 +-
pulsar/internal/lookup_service.go | 25 +-
pulsar/internal/lookup_service_test.go | 83 +-
pulsar/internal/metrics.go | 177 +-
pulsar/internal/pulsar_proto/PulsarApi.pb.go | 32563 +++++--------------
pulsar/internal/pulsar_proto/PulsarApi.proto | 157 +-
pulsar/internal/pulsar_proto/README.md | 12 +-
.../pulsartracing/consumer_interceptor_test.go | 20 +-
.../pulsartracing/message_carrier_util_test.go | 3 +
pulsar/internal/rpc_client.go | 4 +-
pulsar/internal/topic_name.go | 3 +
pulsar/internal/topic_name_test.go | 12 +-
pulsar/internal/utils.go | 15 +
pulsar/internal/utils_test.go | 5 +
pulsar/internal/{checksum_test.go => version.go} | 46 +-
.../{http_client_go_1.12.go => version_test.go} | 13 +-
pulsar/log/wrapper_logrus.go | 16 +-
pulsar/message.go | 18 +
pulsar/message_chunking_test.go | 570 +
.../namespace_name_test.go => message_test.go} | 10 +-
pulsar/negative_acks_tracker.go | 4 +-
pulsar/negative_acks_tracker_test.go | 22 +-
pulsar/negative_backoff_policy.go | 19 +-
pulsar/negative_backoff_policy_test.go | 5 +-
pulsar/producer.go | 36 +
pulsar/producer_impl.go | 4 +
pulsar/producer_partition.go | 666 +-
pulsar/producer_test.go | 399 +-
pulsar/reader.go | 6 +
pulsar/reader_impl.go | 7 +-
pulsar/reader_test.go | 87 +
pulsar/retry_router.go | 17 +-
pulsar/schema.go | 97 +-
pulsar/schema_test.go | 15 +-
pulsar/table_view_impl.go | 14 +-
pulsar/table_view_test.go | 65 +
.../pulsar-test-service-start.sh | 0
.../pulsar-test-service-stop.sh | 0
run-ci.sh => scripts/run-ci.sh | 8 +-
stable.txt | 2 +-
107 files changed, 13152 insertions(+), 26422 deletions(-)
delete mode 100644 .github/workflows/go.yml
rename docker-ci.sh => Makefile (58%)
mode change 100755 => 100644
create mode 100644 integration-tests/conf/.htpasswd
rename integration-tests/{ => conf}/client.conf (100%)
rename integration-tests/{ => conf}/standalone.conf (98%)
create mode 100644 oauth2/client_credentials_provider_test.go
create mode 100644 oauth2/data_url.go
create mode 100644 oauth2/data_url_test.go
delete mode 100644 oauth2/go.mod
delete mode 100644 oauth2/go.sum
rename pulsar/{internal => }/auth/athenz.go (98%)
rename pulsar/{internal => }/auth/athenz_test.go (94%)
create mode 100644 pulsar/auth/basic.go
create mode 100644 pulsar/auth/basic_test.go
rename pulsar/{internal => }/auth/disabled.go (100%)
rename pulsar/{internal => }/auth/oauth2.go (100%)
rename pulsar/{internal => }/auth/oauth2_test.go (98%)
rename pulsar/{internal => }/auth/provider.go (95%)
rename pulsar/{internal => }/auth/tls.go (100%)
rename pulsar/{internal => }/auth/token.go (98%)
rename pulsar/{test_helper.go => helper_for_test.go} (98%)
delete mode 100644 pulsar/internal/http_client_go_1.11.go
copy pulsar/internal/{checksum_test.go => version.go} (54%)
rename pulsar/internal/{http_client_go_1.12.go => version_test.go} (83%)
create mode 100644 pulsar/message_chunking_test.go
copy pulsar/{internal/namespace_name_test.go => message_test.go} (80%)
rename pulsar-test-service-start.sh => scripts/pulsar-test-service-start.sh
(100%)
rename pulsar-test-service-stop.sh => scripts/pulsar-test-service-stop.sh
(100%)
rename run-ci.sh => scripts/run-ci.sh (84%)
