This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
from 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
No new revisions were added by this update.
Summary of changes:
Makefile | 1 +
go.mod | 5 +-
go.sum | 1 -
pulsaradmin/CONTRIBUTING.md | 60 ++
pulsaradmin/README.md | 114 +++
.../noop_encryptor.go => pulsaradmin/alias.go | 21 +-
pulsaradmin/pkg/admin/admin.go | 114 +++
pulsaradmin/pkg/admin/admin_test.go | 109 +++
pulsaradmin/pkg/admin/auth/oauth2.go | 253 ++++++
.../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 | 330 ++++----
.../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 | 28 +-
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 | 33 +-
.../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 | 8 +-
.../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 +-
.../pkg/utils/utils.go | 23 +-
.../pkg/utils/utils_test.go | 63 +-
pulsaradmin/pkg/utils/window_confing.go | 39 +
.../pkg/utils/worker_info.go | 19 +-
94 files changed, 9099 insertions(+), 718 deletions(-)
create mode 100644 pulsaradmin/CONTRIBUTING.md
create mode 100644 pulsaradmin/README.md
copy pulsar/internal/crypto/noop_encryptor.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/message_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 (50%)
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/crypto/noop_decryptor.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/batcher_builder.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/internal/closable.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 pulsar/internal/crypto/noop_encryptor.go =>
pulsaradmin/pkg/utils/utils.go (67%)
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%)
