You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by gi...@apache.org on 2023/11/04 03:15:14 UTC
(pulsar-client-go) branch dependabot/go_modules/golang.org/x/text-0.3.8 updated (aed83e8d -> f38254c1)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/go_modules/golang.org/x/text-0.3.8
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
omit aed83e8d Bump golang.org/x/text from 0.3.7 to 0.3.8
add 257a9c84 fix:when send error, nack the message (#592)
add b8563cd8 [feat]: Support auto scaled consumer receiver queue (#976)
add 04ad521e Fix batched messages not ACKed correctly when batch index ACK is disabled (#994)
add 6c3ee77e fix: fix retryAssert (#996)
add 20291f5c [feat] Support consumer client memory limit (#991)
add 09dea663 [feat][txn]Implement transactionImpl (#984)
add 732f3d09 Add 0.10.0 change log (#997)
add 4836eacf [Doc] Fix missing link in the release process (#1000)
add 16b1fa34 ci: stablize golangci-lint task (#1007)
add 2154d70c Fix reconnection backoff logic (#1008)
add 55f0c7cf [improve][ci] try to fix bot workflow (#910)
add fc4f2892 [feat][schema] Support the schema type ProtoNativeSchema (#1006)
add 2437caa1 [feat][txn]Implement transactional consumer/producer API (#1002)
add d51e2920 [Doc] Add links to client docs and feature matrix in README.md (#1014)
add 3367cc0c [fix][Flaky Test] Fix flaky test TestMaxPendingChunkMessages() (#1003)
add 3f4a18b7 [fix] Fix flaky test in `negative_acks_tracker_test.go` (#1017)
add 27e36250 [fix] Fix event time not being set when batching is disabled (#1015)
add 2eb34051 fix: use maphash instead of crypto/sha256 for hash function of hashmap in Schema.hash() (#1022)
add 4c8246c7 chore: improve logs on failTimeoutMessages (#1025)
add 81103045 fix: Delete LICENSE-go-rate.txt (#1028)
add 5a1824b4 [Issue 468] Add Support for NonDurable subscriptions (#992)
add 6acecf06 Fix broken master by upgrading JRE to 17 (#1030)
add 7f91b2bc [Issue 1027][producer] fix: split sendRequest and make reconnectToBroker and other operate in the same coroutine (#1029)
add 56c96911 fix: install openjdk-17 in Dockerfile (#1037)
add 5f825166 Allow user to specify TLS ciphers an min/max TLS version (#1041)
add 3a4e5cfb Add single partition router (#999)
add 3da3e5d4 [fix] Fix ordering key not being set and parsed when batching is disabled (#1034)
add 6f01a7ce [Fix] check if callback is nil before calling it (#1036)
add 5f8df278 [Refactor] refactor duplicated code lines and fix typo errors (#1039)
add 163cd7e5 [Improve] improve the perf of schema and schema cache (#1033)
add aa664716 [Fix] return when registerSendOrAckOp() failed (#1045)
add b4d6d588 Fix the wrong link in the relesae process (#1050)
add 8d451378 [Fix][Producer] check if message is nil (#1047)
add 43986b16 Add 0.11.0 change log (#1048)
add dd920ef2 [fix] Fix 0.11.0 change log (#1054)
add be357401 [fix] [issue 877] Fix ctx in partitionProducer.Send() is not performing as expected (#1053)
add e45122c2 [Fix][Producer] Stop block request even if Value and Payload are both set (#1052)
add 3812c07a [Improve][Producer] simplify the flush logic (#1049)
add 28f61d2f [fix] [issue 1051]: Fix inaccurate producer mem limit in chunking and schema (#1055)
add d4e08c69 [fix] Send Close Command on Producer/Consumer create timeout (#1061)
add 9867c29c [fix] [issue 1057]: Fix the producer flush opertion is not guarantee to flush all messages (#1058)
add 4bfd4aae [fix] [issue 1064] Fix the panic when try to flush in DisableBatching=true (#1065)
add 59ef32b0 [fix][txn] Fix the transaction acknowledgement and send logic for chunk message (#1069)
add a3fcc9a5 [fix] Close consumer resources if creation fails (#1070)
add 16a02993 Fix: client reconnected every authenticationRefreshCheckSeconds when using tls authentication (#1062)
add 50015d30 [fix] Correct the SendAsync() description (#1066)
add 8828c017 ci: replace license header checker and formatter (#1077)
add c49345ca chore: allow rebase and merge (#1080)
add a561477a Create new CODEOWNERS file
add 01b97be9 Initialize the pulsarctl project (streamnative/pulsarctl#1)
add 9f80a95a Add post request for project (streamnative/pulsarctl#7)
add 64b9813c Add cluster commands `get` (streamnative/pulsarctl#4)
add 54e7ebbc Make API version configurable (streamnative/pulsarctl#16)
add ab9e0195 Add auth logic for `pulsarctl` (streamnative/pulsarctl#20)
add 25c6db28 Add command cluster `update` (streamnative/pulsarctl#17)
add 30be14ba Add command cluster `update-peer-clusters` (streamnative/pulsarctl#18)
add 61615ea0 Add command cluster `get-peer-clusters` (streamnative/pulsarctl#19)
add 1f646f5a Add create cmd of Pulsar Functions (streamnative/pulsarctl#15)
add 413d39d6 Add stop cmd for Pulsar Functions (streamnative/pulsarctl#25)
add 24d87768 Add command cluster `create-failure-domain` (streamnative/pulsarctl#21)
add 83ae0df8 Add delete cmd for Pulsar Functions (streamnative/pulsarctl#26)
add 0df6b4fb Add command cluster `get-failure-domain` (streamnative/pulsarctl#22)
add ef44052f Add start cmd for Pulsar Functions (streamnative/pulsarctl#29)
add f5ca38df Add command cluster `list-failure-domains` (streamnative/pulsarctl#23)
add 1d49befa Add restart, list and get cmd for Pulsar Functions (streamnative/pulsarctl#30)
add b4809263 Add update cmd for Pulsar Functions (streamnative/pulsarctl#33)
add d519e6b7 Add command cluster `delete-failure-domain` (streamnative/pulsarctl#24)
add 35303199 Add namespace and topic name check (streamnative/pulsarctl#37)
add a763f370 Add more tests and add encode topic method (streamnative/pulsarctl#38)
add 265c0267 Add command cluster `update_failure_domain` (streamnative/pulsarctl#36)
add 428fb716 Add tenants related commands (streamnative/pulsarctl#28)
add 8cce397b Add stats, status, querystate, putstate, trigger cmds for Pulsar Functions (streamnative/pulsarctl#34)
add 35f14cce Add partitioned topic command CURD (streamnative/pulsarctl#35)
add 88b8ada3 Add source command for pulsarctl (streamnative/pulsarctl#45)
add 1086ee3c [issue:50] fix response status code error (streamnative/pulsarctl#53)
add 5db1e694 Add command topic `lookup` and `bundle-range` (streamnative/pulsarctl#44)
add 848ab635 Add schemas commands for pulsarctl (streamnative/pulsarctl#52)
add 50fe6e25 Add sink commands for pulsarctl (streamnative/pulsarctl#47)
add 66ed4207 Add command topic `last-message-id` (streamnative/pulsarctl#42)
add 24257e4b Add create, delete, list, policies, topic commands for namespace ctl (streamnative/pulsarctl#57)
add 24d7160f Add backlog, retention and ttl commands for pulsarctl (streamnative/pulsarctl#61)
add 20dbbd2d Revert "Add backlog, retention and ttl commands for pulsarctl (streamnative/pulsarctl#61)" (#62)
add 416e8c8d Add topic stats command (streamnative/pulsarctl#46)
add 04bfc275 Add antiAffinityGroup, persistence, clusters, unload, spliteBundle and deduplication for pulsartl (streamnative/pulsarctl#66)
add 2efdd3c2 Add topic permissions commands (streamnative/pulsarctl#48)
add 13c4241e Add license header check for all files (streamnative/pulsarctl#69)
add 896c9151 Add command topic `internal-info` (streamnative/pulsarctl#51)
add 1939c6ca Add command unsubscribe and clearBacklog and command set and get for dispatch and subscribe and replicator rate (streamnative/pulsarctl#68)
add 483bf169 Add golangci-lint to check project style (streamnative/pulsarctl#78)
add 8a091d21 Add website for pulsarctl (streamnative/pulsarctl#77)
add 608b23dc Add topic command `compact` and `compact-status` (streamnative/pulsarctl#75)
add f27c2ec6 Add topic command `unload` (streamnative/pulsarctl#76)
add 9ac28447 Add namespaces permissions commands (streamnative/pulsarctl#71)
add 963abf5f Add topic command `offload` and `offload-status` (streamnative/pulsarctl#74)
add a4da6e5d Add topic command `terminate` (streamnative/pulsarctl#73)
add 4e8331d0 Add set and get commands for MaxConsumersPerSub and MaxConsumersPerTopic and maxProduersPerTopic (streamnative/pulsarctl#67)
add 6aa9eb42 Add schema, offload and compaction commands of namespaces for pulsasrctl (streamnative/pulsarctl#64)
add f5ae61c8 Add subscription commands (streamnative/pulsarctl#58)
add d1079559 Add broker-stats commands for pulsarctl (streamnative/pulsarctl#84)
add e674a050 Add broker commands for pulsarctl (streamnative/pulsarctl#87)
add 8686ad4c Provide the token auth (streamnative/pulsarctl#91)
add 3013a265 Add pulsarctl version info (streamnative/pulsarctl#95)
add 23529927 Add comments for admin api (streamnative/pulsarctl#104)
add 29fc614b Add timeout for the http client (streamnative/pulsarctl#93)
add 5467ad13 Add `SCOPE` for topic commands (streamnative/pulsarctl#72)
add 8e26bddb Add ns-isolation-policy commands for pulsarctl (streamnative/pulsarctl#88)
add a4b64d6e Add functions-worker commands for pulsarctl (streamnative/pulsarctl#92)
add 5abac5c3 Add resource-quotas commands for pulsarctl (streamnative/pulsarctl#90)
add 2fcad0cc Refactor pulsar pkg for pulsarctl (streamnative/pulsarctl#124)
add 3328f85c [Issue:128] Fix deploying python function (streamnative/pulsarctl#130)
add 4ae5e142 Move description.go to cmdutils (streamnative/pulsarctl#133)
add 91cd5d4f [BK-SUPPORT-PART-1] Separate HTTP client and admin client (streamnative/pulsarctl#132)
add ef393388 Support create key pair command (streamnative/pulsarctl#149)
add ebf02a54 Support create secret key command (streamnative/pulsarctl#145)
add 58efddb3 Support create token command (streamnative/pulsarctl#150)
add 38d126c7 Support validate token command (streamnative/pulsarctl#151)
add 07657c34 Support show a token content (streamnative/pulsarctl#152)
add aa0d4f85 Fixes error handle for bookKeeper error message (streamnative/pulsarctl#155)
add bf0f7496 Fixes unexpected error when request using pulsar 2.4.2 proxy (streamnative/pulsarctl#157)
add b368faf0 Fix wrong http header when receive pulsar header (streamnative/pulsarctl#165)
add 00f1a5d1 Using testcontainer to create a test framework for testing (streamnative/pulsarctl#167)
add cc95102e Add test for the auto recovery command (streamnative/pulsarctl#170)
add 019124ec Add context for pulsarctl (streamnative/pulsarctl#169)
add 65c6c27b [issue-126] Implement JSON output format for list commands (streamnative/pulsarctl#181)
add 9bd3f229 Rework auth and add pulsar client conf (streamnative/pulsarctl#196)
add 0ee48325 [issue:197]Check Nil interface the right way (streamnative/pulsarctl#198)
add 46f9c69b [issue:182] get-function-assignments has incorrect output (streamnative/pulsarctl#199)
add 96d284a7 Change NameSpaceAuth to be an [] of AuthAction (streamnative/pulsarctl#202)
add 1441aa09 Add RetentionPolicy parsing (streamnative/pulsarctl#201)
add ecb95e70 [Issue 183] Fixes can not parse the `destination_auth` (streamnative/pulsarctl#204)
add aeda3fef [Issue 180] Make error log use stderr (streamnative/pulsarctl#206)
add e06dc227 Add download command for functions CLI (streamnative/pulsarctl#221)
add 2827b6d6 Fixes nil pointer when using tls (streamnative/pulsarctl#231)
add 88f9f0ef Support oauth2 authentication for pulsarctl (streamnative/pulsarctl#233)
add d1a43f8b Improve the oauth2 implementation (streamnative/pulsarctl#237)
add bdaa430d Fix the TLS not working when enable the oauth2 authentication (streamnative/pulsarctl#242)
add c6f7ddff Fixes default api version to be v2 (streamnative/pulsarctl#250)
add 806a394d Escape special characters in parts of the URL (streamnative/pulsarctl#252)
add 25389b25 Improve the current unit tests (streamnative/pulsarctl#253)
add 0f3d1b5d Updating fields in utils data (streamnative/pulsarctl#254)
add 2e353e1d Improve the current CI checks (streamnative/pulsarctl#258)
add ad4a9650 Handle the null response body (streamnative/pulsarctl#272)
add 1586533d Fix the function download command issue (streamnative/pulsarctl#275)
add 28a98b95 Upgrade dependencies (streamnative/pulsarctl#285)
add 8c409bce Fix the error introduce from the latest pulsar (streamnative/pulsarctl#284)
add dea508e3 Adds namespace topic auto-creation configuration (streamnative/pulsarctl#297)
add c2488beb Clone default transport instead of modifying directly (streamnative/pulsarctl#299)
add 7cf3aff3 Adds the `isOffloaded` field (streamnative/pulsarctl#288)
add 60bafa02 Add command topic message ttl. (streamnative/pulsarctl#246) (#348)
add 9daf4ab5 Add command topic max producers. (streamnative/pulsarctl#246) (#353)
add 8690a147 Add command topic max consumers. (streamnative/pulsarctl#246) (#355)
add 1f31f3a8 Add command topic max unacked messages per consumer. (streamnative/pulsarctl#246) (#358)
add 6c6c5013 Add command topic max unacked messages per subscription. (streamnative/pulsarctl#246) (#361)
add 0aeb9f7a Add command topic Persistence Policy. (streamnative/pulsarctl#246) (#363)
add d6441616 Support using Json to configure the token auth provider (streamnative/pulsarctl#368)
add d5b6ddfb Support use short auth name to configure auth (streamnative/pulsarctl#371)
add 93c0e452 Bump version to 2.8.0-rc-202106151929 (streamnative/pulsarctl#372)
add 6f562454 Add command topic Delayed Delivery Policies. (streamnative/pulsarctl#246) (#374)
add 1d7be34c Add command topic message dispatch rate. (streamnative/pulsarctl#246) (#397)
add bbb7854c Fix the 400 error when create function (streamnative/pulsarctl#405)
add 9e9f3827 Add command topic Deduplication(streamnative/pulsarctl#246) (#408)
add a76197d2 fix: check the parse service url for errors (streamnative/pulsarctl#395)
add 11358b6a Fix the sink and source tests (streamnative/pulsarctl#411)
add 8c6a1230 Remove unknown error (streamnative/pulsarctl#422)
add b17d7a5b add pulsarctl namespace/topic set-publish-rate (streamnative/pulsarctl#428)
add 440de491 feat: add get/remove/set retention policy command for topic (streamnative/pulsarctl#420)
add 87aacec0 feat: add compaction threshold command for topic (streamnative/pulsarctl#430)
add 94854122 feat: add backlog quota command for topic (streamnative/pulsarctl#429)
add 228728e0 Add customRuntimeOptions to sinks and functions (streamnative/pulsarctl#449)
add 2ab48f8e add packages management service APIs (streamnative/pulsarctl#450)
add a9d3a3dd fix packages cmds (streamnative/pulsarctl#458)
add 968ad573 feat: add inactive topic policies command for topic (streamnative/pulsarctl#444)
add 2fbf81ab fix: fix checks the packages url and file path of the upload package (streamnative/pulsarctl#460)
add eaa13e63 OAuth 2.0 Usability Improvements (+Azure AD) (streamnative/pulsarctl#465)
add 5bbd7b6c Add support for sourceSubscriptionName to sinks (streamnative/pulsarctl#469)
add 887c85ca Support BacklogQuotaType when setting namespace backlog. (streamnative/pulsarctl#480)
add 30f982c8 fix: improve parse response avoid parse the empty body (streamnative/pulsarctl#491)
add c6c87901 Remove omitempty from booleans (streamnative/pulsarctl#500)
add a8694b2f ParseAuthAction supports new actions (streamnative/pulsarctl#512)
add 4cbb79af fix: improve new client with auth provider (streamnative/pulsarctl#518)
add fb814434 bump pulsar-client-go/oauth2 (streamnative/pulsarctl#533)
add 39777320 fix: update type in namespace policies (streamnative/pulsarctl#556)
add d30fc372 feat: add allow auto update schema cmd (streamnative/pulsarctl#567)
add f32046d9 fix: create non-partitions topic (streamnative/pulsarctl#577)
add 725f1bda fix: fix encode json body (streamnative/pulsarctl#610)
add 3a9f0e28 fix: use nil instead of empty string as request body (streamnative/pulsarctl#662)
add ca8e2d88 support build with go 1.18 (streamnative/pulsarctl#699)
add 342f1d67 fix: fix tls insecure connection (streamnative/pulsarctl#731)
add a45fe8ef Fix test new with custom auth provider (streamnative/pulsarctl#734)
add 353aa4e9 fix: Remove encoding for the topic (streamnative/pulsarctl#828)
add 544789ed Update pulsarctl go version (streamnative/pulsarctl#853)
add e39a7e17 add fields to topic stats (streamnative/pulsarctl#858)
add c382d67a add estimated backlog size as measure of unconsumed messages (streamnative/pulsarctl#860)
add b0a5862c support oauth2 with auth params (streamnative/pulsarctl#876)
add 1cbd268d update resource keys to match comments (streamnative/pulsarctl#879)
add aab8634f Add get-message-by-id command (streamnative/pulsarctl#882)
add d0ffd401 fix: add miss fields to PersistentTopicInternalStats (streamnative/pulsarctl#477)
add c6f2db8b Upgrade jwt package, support custom claim and header (streamnative/pulsarctl#906)
add 56cbec9c Fix the wrong field of the internal stats and internal info (streamnative/pulsarctl#907)
add 68dc725a feat: support delete a subscription forcefully (streamnative/pulsarctl#609)
add a05b06eb fix: fix token exp (streamnative/pulsarctl#976)
add 588ecb12 Add auth parameter to cluster management (streamnative/pulsarctl#986)
add 2a2af482 chore: go mod tidy
add f18cc6ec chore: add gitignore
add b353c8af Bump golang.org/x/net from 0.0.0-20220225172249-27dd8689420f to 0.7.0 (streamnative/pulsar-admin-go#2)
add 8fa6c3a9 Optimize project layout (streamnative/pulsar-admin-go#3)
add 786076ac Decouple config and auth package (streamnative/pulsar-admin-go#4)
add eca3965b Add alias package (streamnative/pulsar-admin-go#5)
add 8c65193e fix: golangci-lint errors (streamnative/pulsar-admin-go#7)
add 735e3c3c ci: add lint and test (streamnative/pulsar-admin-go#6)
add 49c38ec4 chore: clean non-admin apis (streamnative/pulsar-admin-go#9)
add 8234bb78 ci: add release workflow (streamnative/pulsar-admin-go#8)
add 87905b05 docs: add README, LICENSE and CONTRIBUTING (streamnative/pulsar-admin-go#10)
add 9edc7fdd fix: change copyright from ASF to StreamNative (streamnative/pulsar-admin-go#11)
add 4314e0e7 ci: add license header checker (streamnative/pulsar-admin-go#12)
add a84988c9 chore: add Makefile (streamnative/pulsar-admin-go#13)
add 2c65139e chore: replace deprecated ioutil pkg (streamnative/pulsar-admin-go#14)
add 6ebe1712 fix: use auth provider as http round tripper (streamnative/pulsar-admin-go#15)
add 4de2b900 fix: config oauth2 with default flow (streamnative/pulsar-admin-go#16)
add 9a6ac59d docs: complete code demo (streamnative/pulsar-admin-go#17)
add a065c93a ci: add conventional commits PR title checker (streamnative/pulsar-admin-go#18)
add e44157d0 docs: update contribution guides (streamnative/pulsar-admin-go#19)
add a6c39fd5 docs: add go reference badge (streamnative/pulsar-admin-go#20)
add ed660397 docs: add go report card badge (streamnative/pulsar-admin-go#21)
add 03bddae6 feat: add new parameters for creating cluster (streamnative/pulsar-admin-go#23)
add 3bf18a81 fix: keyring file dir path (streamnative/pulsar-admin-go#26)
add 3b2df30a feat: Align function/sink/source config with pulsar master(@2b01f83e) (streamnative/pulsar-admin-go#29)
add 521ee5de feat: add GetMessageID api (streamnative/pulsar-admin-go#28)
add 87035204 feat: adds support for namespace scoped inactive topic policies (streamnative/pulsar-admin-go#30) (#31)
add fbf09667 chore: add pull request template (streamnative/pulsar-admin-go#33)
add 1be51339 feat: create parent dir for package downloading when necessary (streamnative/pulsar-admin-go#35)
add dd5b83b3 fix: use pointer for struct field so the default value from unmarshal is nil (streamnative/pulsar-admin-go#36)
add de96e174 fix: remove omitempty for bool value (streamnative/pulsar-admin-go#38)
add eee6d76e fix: Fix wrong model field (streamnative/pulsar-admin-go#42)
add 750e8e9d chore: tidy pulsar-admin-go sources
add 71afeb2e replace license header
add fbee610d revrert: allow rebase and merge (#1081)
add 41093516 fix(producer): fail all messages that are pending requests when closing (#1059)
add 28a6b491 Support load config from env (#1089)
add 2a15a251 [Fix] Multiple calls to client.Close causes panic (#1046)
add 7fef6a98 [improve][client] Implement GetLastMSgID for Reader (#1087)
add f979c183 [fix] Fix comment for ConnectionMaxIdleTime (#1091)
add 7cf643be connectionTimeout respects net.Dialer default timeout (#1095)
add ac9c1a63 Support OAuth2 with scope field (#1097)
add 0bf2f9b8 Fix issue where DisableReplication flag does not work (#1100)
add da06dca2 dobule check before consumer reconnect (#1084)
add f5667b24 fix: fix schema error (#823)
add 59c7eaee refactor: rename pendingItem.Complete() to pendingItem.done() (#1109)
add f9969ca8 feat: add sendRequest.done() to release resource together (#1110)
add e61e9666 Revert "feat: add sendRequest.done() to release resource together (#1110)"
add af56e603 refactor: factor out validateMsg (#1117)
add 1b135f44 refactor: factor out prepareTransaction (#1118)
add e3046f81 chore: Complete comment on ProducerInterceptor interface BeforeSend method (#1119)
add 793008e7 refactor: prepare sendrequest and move to internalSendAsync (#1120)
add 7c14fb7a fix: normalize all send request resource release into sr.done (#1121)
add 2a8d1512 [imporve] add func blockIfQueueFull() to encapsulate DisableBlockIfQueueFull (#1122)
add 620ecf4a [improve] make debug log more clearer in ReceivedSendReceipt() (#1123)
add 0845e738 [fix][issue 1098] check batchBuilder in case batch is disabled (#1099)
add 64c87a0a [Fix][Producer] Reconnection backoff logic for producer (#1125)
add f38254c1 Bump golang.org/x/text from 0.3.7 to 0.3.8
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 (aed83e8d)
\
N -- N -- N refs/heads/dependabot/go_modules/golang.org/x/text-0.3.8 (f38254c1)
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:
.asf.yaml | 2 -
.github/workflows/bot.yml | 39 +-
.github/workflows/ci.yml | 50 +
.github/workflows/project.yml | 39 -
.golangci.yml | 22 +-
CHANGELOG.md | 123 +++
Dockerfile | 4 +-
Makefile | 12 +-
README.md | 14 +-
VERSION | 2 +-
distribution/license/LICENSE-go-rate.txt | 675 ------------
docs/release-process.md | 4 +-
go.mod | 5 +-
go.sum | 3 +-
integration-tests/certs/generate.sh | 3 +-
integration-tests/license_test.go | 118 ---
integration-tests/pb/build.sh | 10 +-
integration-tests/pb/hello.pb.go | 142 ++-
integration-tests/pb/hello.proto | 15 +-
integration-tests/pb/{hello.pb.go => hi.pb.go} | 104 +-
integration-tests/pb/{hello.proto => hi.proto} | 11 +-
integration-tests/pb/build.sh => licenserc.toml | 12 +-
perf/perf-consumer.go | 26 +-
perf/pulsar-perf-go.go | 6 +
pulsar/client.go | 22 +-
pulsar/client_impl.go | 41 +-
pulsar/client_impl_test.go | 7 +
pulsar/consumer.go | 13 +
pulsar/consumer_impl.go | 13 +-
pulsar/consumer_multitopic.go | 17 +
pulsar/consumer_partition.go | 363 +++++--
pulsar/consumer_partition_test.go | 3 +
pulsar/consumer_regex.go | 18 +
pulsar/consumer_test.go | 398 +++++++
pulsar/dlq_router.go | 18 +-
pulsar/error.go | 28 +-
pulsar/helper_for_test.go | 9 +-
pulsar/impl_message.go | 4 +
pulsar/internal/batch_builder.go | 8 +
pulsar/internal/commands.go | 12 +-
pulsar/internal/connection.go | 19 +-
pulsar/internal/http_client.go | 8 +-
pulsar/internal/key_based_batch_builder.go | 5 +-
pulsar/internal/memory_limit_controller.go | 58 +-
pulsar/internal/memory_limit_controller_test.go | 63 +-
pulsar/internal/pulsar_proto/PulsarApi.proto | 3 +-
.../pulsartracing/consumer_interceptor_test.go | 4 +
pulsar/message.go | 4 +
pulsar/message_chunking_test.go | 153 +--
pulsar/negative_acks_tracker_test.go | 5 +-
pulsar/producer.go | 3 +-
pulsar/producer_interceptor.go | 1 +
pulsar/producer_partition.go | 1104 ++++++++++++--------
pulsar/producer_test.go | 483 +++++++++
pulsar/reader.go | 3 +
pulsar/reader_impl.go | 6 +-
pulsar/reader_test.go | 42 +
pulsar/schema.go | 107 +-
pulsar/schema_test.go | 65 +-
.../{helper_test.go => single_partition_router.go} | 40 +-
...per_test.go => single_partition_router_test.go} | 56 +-
pulsar/transaction.go | 50 +-
pulsar/transaction_coordinator_client.go | 47 +-
pulsar/transaction_impl.go | 239 +++++
pulsar/transaction_test.go | 461 +++++++-
pulsaradmin/CONTRIBUTING.md | 60 ++
pulsaradmin/README.md | 114 ++
.../buffer_test.go => pulsaradmin/alias.go | 26 +-
pulsaradmin/pkg/admin/admin.go | 114 ++
pulsaradmin/pkg/admin/admin_test.go | 109 ++
pulsaradmin/pkg/admin/auth/oauth2.go | 262 +++++
.../pkg/admin}/auth/oauth2_test.go | 91 +-
pulsaradmin/pkg/admin/auth/provider.go | 96 ++
{pulsar => pulsaradmin/pkg/admin}/auth/tls.go | 95 +-
pulsaradmin/pkg/admin/auth/token.go | 97 ++
pulsaradmin/pkg/admin/auth/transport.go | 60 ++
pulsaradmin/pkg/admin/broker_stats.go | 105 ++
pulsaradmin/pkg/admin/brokers.go | 156 +++
pulsaradmin/pkg/admin/cluster.go | 142 +++
.../pkg/admin/config/api_version.go | 30 +-
.../pkg/admin/config/api_version_test.go | 10 +-
pulsaradmin/pkg/admin/config/config.go | 52 +
pulsaradmin/pkg/admin/functions.go | 686 ++++++++++++
pulsaradmin/pkg/admin/functions_worker.go | 103 ++
pulsaradmin/pkg/admin/namespace.go | 875 ++++++++++++++++
pulsaradmin/pkg/admin/ns_isolation_policy.go | 114 ++
pulsaradmin/pkg/admin/packages.go | 255 +++++
pulsaradmin/pkg/admin/resource_quotas.go | 86 ++
pulsaradmin/pkg/admin/schema.go | 138 +++
pulsaradmin/pkg/admin/sinks.go | 437 ++++++++
pulsaradmin/pkg/admin/sources.go | 440 ++++++++
pulsaradmin/pkg/admin/subscription.go | 316 ++++++
pulsaradmin/pkg/admin/tenant.go | 82 ++
pulsaradmin/pkg/admin/topic.go | 725 +++++++++++++
.../pkg/rest/client.go | 322 +++---
.../pkg/rest/client_test.go | 37 +-
.../pkg/rest/errors.go | 23 +-
pulsaradmin/pkg/utils/allocator_stats.go | 72 ++
pulsaradmin/pkg/utils/auth_action.go | 55 +
.../pkg/utils/auth_polices.go | 29 +-
pulsaradmin/pkg/utils/auth_polices_test.go | 65 ++
pulsaradmin/pkg/utils/backlog_quota.go | 83 ++
.../pkg/utils/batch_source_config.go | 17 +-
.../pkg/utils/broker_ns_isolation_data.go | 15 +-
.../pkg/utils/bundles_data.go | 41 +-
.../pkg/utils/connector_definition.go | 37 +-
.../pkg/utils/consumer_config.go | 47 +-
.../pkg/utils/crypto_config.go | 33 +-
pulsaradmin/pkg/utils/data.go | 467 +++++++++
.../pkg/utils/dispatch_rate.go | 42 +-
pulsaradmin/pkg/utils/function_confg.go | 94 ++
.../pkg/utils/function_state.go | 16 +-
pulsaradmin/pkg/utils/function_status.go | 49 +
pulsaradmin/pkg/utils/functions_stats.go | 145 +++
pulsaradmin/pkg/utils/home_dir.go | 97 ++
pulsaradmin/pkg/utils/inactive_topic_policies.go | 59 ++
.../pkg/utils/internal_configuration_data.go | 13 +-
pulsaradmin/pkg/utils/load_manage_report.go | 156 +++
.../pkg/utils/long_running_process_status.go | 32 +-
pulsaradmin/pkg/utils/message.go | 91 ++
pulsaradmin/pkg/utils/message_id.go | 82 ++
pulsaradmin/pkg/utils/message_id_test.go | 65 ++
.../pkg/utils/metrics.go | 20 +-
pulsaradmin/pkg/utils/namespace_name.go | 88 ++
pulsaradmin/pkg/utils/namespace_name_test.go | 64 ++
pulsaradmin/pkg/utils/ns_isolation_data.go | 95 ++
.../pkg/utils/ns_ownership_status.go | 22 +-
.../pkg/utils/package_metadata.go | 10 +-
pulsaradmin/pkg/utils/package_name.go | 116 ++
pulsaradmin/pkg/utils/package_name_test.go | 73 ++
.../pkg/utils/package_type.go | 36 +-
pulsaradmin/pkg/utils/persistence_policies.go | 40 +
pulsaradmin/pkg/utils/policies.go | 79 ++
.../pkg/utils/producer_config.go | 35 +-
.../pkg/utils/publish_rate.go | 20 +-
.../pkg/utils/resource_quota.go | 50 +-
.../pkg/utils/resources.go | 28 +-
.../pkg/utils/retention_policies.go | 21 +-
pulsaradmin/pkg/utils/schema_strategy.go | 60 ++
pulsaradmin/pkg/utils/schema_util.go | 69 ++
pulsaradmin/pkg/utils/sink_config.go | 67 ++
pulsaradmin/pkg/utils/sink_status.go | 67 ++
pulsaradmin/pkg/utils/source_config.go | 52 +
pulsaradmin/pkg/utils/source_status.go | 43 +
.../pkg/utils/subscription_auth_mode.go | 29 +-
.../pkg/utils/topic_auto_creation_config.go | 9 +-
.../pkg/utils/topic_domain.go | 33 +-
pulsaradmin/pkg/utils/topic_name.go | 155 +++
pulsaradmin/pkg/utils/topic_name_test.go | 75 ++
.../pkg/utils/topic_type.go | 33 +-
.../pkg/utils/topics_stats_stream.go | 12 +-
.../pkg/utils/update_options.go | 17 +-
.../reader.go => pulsaradmin/pkg/utils/utils.go | 48 +-
.../pkg/utils/utils_test.go | 63 +-
pulsaradmin/pkg/utils/window_confing.go | 39 +
.../pkg/utils/worker_info.go | 19 +-
scripts/pulsar-test-service-start.sh | 3 +-
scripts/pulsar-test-service-stop.sh | 3 +-
scripts/run-ci.sh | 3 +-
stable.txt | 2 +-
160 files changed, 12891 insertions(+), 2411 deletions(-)
create mode 100644 .github/workflows/ci.yml
delete mode 100644 .github/workflows/project.yml
delete mode 100644 distribution/license/LICENSE-go-rate.txt
delete mode 100644 integration-tests/license_test.go
copy integration-tests/pb/{hello.pb.go => hi.pb.go} (51%)
copy integration-tests/pb/{hello.proto => hi.proto} (90%)
copy integration-tests/pb/build.sh => licenserc.toml (87%)
mode change 100755 => 100644
mode change 100644 => 100755 pulsar/producer_partition.go
copy pulsar/{helper_test.go => single_partition_router.go} (59%)
copy pulsar/{helper_test.go => single_partition_router_test.go} (50%)
create mode 100644 pulsar/transaction_impl.go
create mode 100644 pulsaradmin/CONTRIBUTING.md
create mode 100644 pulsaradmin/README.md
copy pulsar/internal/buffer_test.go => pulsaradmin/alias.go (65%)
create mode 100644 pulsaradmin/pkg/admin/admin.go
create mode 100644 pulsaradmin/pkg/admin/admin_test.go
create mode 100644 pulsaradmin/pkg/admin/auth/oauth2.go
copy {pulsar => pulsaradmin/pkg/admin}/auth/oauth2_test.go (66%)
create mode 100644 pulsaradmin/pkg/admin/auth/provider.go
copy {pulsar => pulsaradmin/pkg/admin}/auth/tls.go (51%)
create mode 100644 pulsaradmin/pkg/admin/auth/token.go
create mode 100644 pulsaradmin/pkg/admin/auth/transport.go
create mode 100644 pulsaradmin/pkg/admin/broker_stats.go
create mode 100644 pulsaradmin/pkg/admin/brokers.go
create mode 100644 pulsaradmin/pkg/admin/cluster.go
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/admin/config/api_version.go (72%)
copy pulsar/internal/version_test.go => pulsaradmin/pkg/admin/config/api_version_test.go (76%)
create mode 100644 pulsaradmin/pkg/admin/config/config.go
create mode 100644 pulsaradmin/pkg/admin/functions.go
create mode 100644 pulsaradmin/pkg/admin/functions_worker.go
create mode 100644 pulsaradmin/pkg/admin/namespace.go
create mode 100644 pulsaradmin/pkg/admin/ns_isolation_policy.go
create mode 100644 pulsaradmin/pkg/admin/packages.go
create mode 100644 pulsaradmin/pkg/admin/resource_quotas.go
create mode 100644 pulsaradmin/pkg/admin/schema.go
create mode 100644 pulsaradmin/pkg/admin/sinks.go
create mode 100644 pulsaradmin/pkg/admin/sources.go
create mode 100644 pulsaradmin/pkg/admin/subscription.go
create mode 100644 pulsaradmin/pkg/admin/tenant.go
create mode 100644 pulsaradmin/pkg/admin/topic.go
copy pulsar/internal/http_client.go => pulsaradmin/pkg/rest/client.go (52%)
copy pulsar/helper_test.go => pulsaradmin/pkg/rest/client_test.go (63%)
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/rest/errors.go (73%)
create mode 100644 pulsaradmin/pkg/utils/allocator_stats.go
create mode 100644 pulsaradmin/pkg/utils/auth_action.go
copy pulsar/internal/hash.go => pulsaradmin/pkg/utils/auth_polices.go (60%)
create mode 100644 pulsaradmin/pkg/utils/auth_polices_test.go
create mode 100644 pulsaradmin/pkg/utils/backlog_quota.go
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/utils/batch_source_config.go (67%)
copy pulsar/internal/version_test.go => pulsaradmin/pkg/utils/broker_ns_isolation_data.go (77%)
copy pulsar/internal/checksum.go => pulsaradmin/pkg/utils/bundles_data.go (58%)
copy pulsar/helper_test.go => pulsaradmin/pkg/utils/connector_definition.go (57%)
copy examples/reader/reader.go => pulsaradmin/pkg/utils/consumer_config.go (50%)
copy pulsar/helper_test.go => pulsaradmin/pkg/utils/crypto_config.go (58%)
create mode 100644 pulsaradmin/pkg/utils/data.go
copy pulsar/internal/checksum.go => pulsaradmin/pkg/utils/dispatch_rate.go (52%)
create mode 100644 pulsaradmin/pkg/utils/function_confg.go
copy pulsar/internal/version_test.go => pulsaradmin/pkg/utils/function_state.go (77%)
create mode 100644 pulsaradmin/pkg/utils/function_status.go
create mode 100644 pulsaradmin/pkg/utils/functions_stats.go
create mode 100644 pulsaradmin/pkg/utils/home_dir.go
create mode 100644 pulsaradmin/pkg/utils/inactive_topic_policies.go
copy pulsar/internal/namespace_name.go => pulsaradmin/pkg/utils/internal_configuration_data.go (72%)
create mode 100644 pulsaradmin/pkg/utils/load_manage_report.go
copy pulsar/internal/crypto/noop_decryptor.go => pulsaradmin/pkg/utils/long_running_process_status.go (60%)
create mode 100644 pulsaradmin/pkg/utils/message.go
create mode 100644 pulsaradmin/pkg/utils/message_id.go
create mode 100644 pulsaradmin/pkg/utils/message_id_test.go
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/utils/metrics.go (73%)
create mode 100644 pulsaradmin/pkg/utils/namespace_name.go
create mode 100644 pulsaradmin/pkg/utils/namespace_name_test.go
create mode 100644 pulsaradmin/pkg/utils/ns_isolation_data.go
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/utils/ns_ownership_status.go (67%)
copy pulsar/internal/closable.go => pulsaradmin/pkg/utils/package_metadata.go (63%)
create mode 100644 pulsaradmin/pkg/utils/package_name.go
create mode 100644 pulsaradmin/pkg/utils/package_name_test.go
copy pulsar/batcher_builder.go => pulsaradmin/pkg/utils/package_type.go (55%)
create mode 100644 pulsaradmin/pkg/utils/persistence_policies.go
create mode 100644 pulsaradmin/pkg/utils/policies.go
copy pulsar/helper_test.go => pulsaradmin/pkg/utils/producer_config.go (56%)
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/utils/publish_rate.go (71%)
copy pulsar/internal/checksum.go => pulsaradmin/pkg/utils/resource_quota.go (54%)
copy pulsar/internal/crypto/noop_encryptor.go => pulsaradmin/pkg/utils/resources.go (70%)
copy pulsar/internal/helper.go => pulsaradmin/pkg/utils/retention_policies.go (67%)
create mode 100644 pulsaradmin/pkg/utils/schema_strategy.go
create mode 100644 pulsaradmin/pkg/utils/schema_util.go
create mode 100644 pulsaradmin/pkg/utils/sink_config.go
create mode 100644 pulsaradmin/pkg/utils/sink_status.go
create mode 100644 pulsaradmin/pkg/utils/source_config.go
create mode 100644 pulsaradmin/pkg/utils/source_status.go
copy pulsar/internal/crypto/noop_encryptor.go => pulsaradmin/pkg/utils/subscription_auth_mode.go (63%)
copy pulsar/transaction.go => pulsaradmin/pkg/utils/topic_auto_creation_config.go (80%)
copy pulsar/batcher_builder.go => pulsaradmin/pkg/utils/topic_domain.go (61%)
create mode 100644 pulsaradmin/pkg/utils/topic_name.go
create mode 100644 pulsaradmin/pkg/utils/topic_name_test.go
copy pulsar/batcher_builder.go => pulsaradmin/pkg/utils/topic_type.go (60%)
copy pulsar/internal/version_test.go => pulsaradmin/pkg/utils/topics_stats_stream.go (81%)
copy pulsar/internal/version_test.go => pulsaradmin/pkg/utils/update_options.go (80%)
copy examples/reader/reader.go => pulsaradmin/pkg/utils/utils.go (55%)
copy pulsar/internal/hash_test.go => pulsaradmin/pkg/utils/utils_test.go (54%)
create mode 100644 pulsaradmin/pkg/utils/window_confing.go
copy pulsar/internal/namespace_name_test.go => pulsaradmin/pkg/utils/worker_info.go (72%)