From 7688de16430818c0fcc09e5c813c8e35c5b49602 Mon Sep 17 00:00:00 2001 From: Vincent de Saboulin Date: Thu, 26 Sep 2024 12:02:21 +0200 Subject: [PATCH] update (#12) --- .../connect-jdbc-sybase-sink/sybase-sink.sh | 3 +- scripts/cli/completions.bash | 880 +++++++++--------- scripts/cli/confluent-hub-plugin-list.txt | 1 + scripts/cli/playground | 320 ++++++- scripts/cli/playground.json | 14 +- scripts/cli/playground.yaml | 14 +- scripts/cli/src/bashly.yml | 25 +- .../src/commands/config/check-repo-version.sh | 2 + .../config/container-kill-all-before-run.sh | 2 + .../commands/connector/create-or-update.sh | 2 +- .../src/commands/connector/select-config.sh | 2 +- .../cli/src/commands/connector/show-config.sh | 4 +- .../cli/src/commands/connector/snippets.sh | 2 +- .../cli/src/commands/container/kill-all.sh | 2 +- .../cli/src/commands/get-docker-compose.sh | 1 + scripts/cli/src/commands/repro/bootstrap.sh | 2 +- scripts/cli/src/commands/run.sh | 22 +- scripts/cli/src/commands/start-environment.sh | 14 +- scripts/cli/src/lib/utils_function.sh | 45 +- 19 files changed, 855 insertions(+), 502 deletions(-) create mode 100644 scripts/cli/src/commands/config/check-repo-version.sh create mode 100644 scripts/cli/src/commands/config/container-kill-all-before-run.sh diff --git a/connect/connect-jdbc-sybase-sink/sybase-sink.sh b/connect/connect-jdbc-sybase-sink/sybase-sink.sh index 9a909ee28..89c7e1516 100755 --- a/connect/connect-jdbc-sybase-sink/sybase-sink.sh +++ b/connect/connect-jdbc-sybase-sink/sybase-sink.sh @@ -16,7 +16,8 @@ playground connector create-or-update --connector sybase-sink << EOF "connection.user": "sa", "connection.password": "password", "topics": "orders", - "auto.create": "true" + "auto.create": "true", + "table.name.format": "master.dbo.orders" } EOF diff --git a/scripts/cli/completions.bash b/scripts/cli/completions.bash index 97dc052cb..0fb603ef2 100644 --- a/scripts/cli/completions.bash +++ b/scripts/cli/completions.bash @@ -48,38 +48,42 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'tcp-proxy toggle-writes-service'*'--connection-id') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") - ;; - *'connector offsets get-offsets-request-status'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'tcp-proxy toggle-reads-service'*'--connection-id') + *'tcp-proxy toggle-writes-service'*'--connection-id') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; - *'tcp-proxy toggle-writes-client'*'--connection-id') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") + *'topic set-schema-compatibility'*'--compatibility') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur") ;; *'connector-plugin search-jar'*'--connector-plugin') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur") ;; - *'topic set-schema-compatibility'*'--compatibility') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur") + *'tcp-proxy toggle-writes-client'*'--connection-id') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; - *'ec2 sync-repro-folder local-to-ec2'*'--instance') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + *'tcp-proxy toggle-reads-service'*'--connection-id') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") + ;; + + *'connector open-ccloud-connector-in-browser'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; *'tcp-proxy toggle-reads-client'*'--connection-id') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; + *'ec2 sync-repro-folder local-to-ec2'*'--instance') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + ;; + *'connector offsets get-offsets-request-status'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; @@ -88,10 +92,6 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; - *'connector open-ccloud-connector-in-browser'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") - ;; - *'connector show-config-parameters'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; @@ -116,10 +116,6 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; - *'tcp-proxy get-connections'*'--connection-id') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") - ;; - *'topic produce'*'--key-subject-name-strategy') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "TopicNameStrategy RecordNameStrategy TopicRecordNameStrategy")" -- "$cur") ;; @@ -128,30 +124,34 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'config open-ccloud-connector-in-browser'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h automatically browser")" -- "$cur") + *'tcp-proxy get-connections'*'--connection-id') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; *'schema set-compatibility'*'--compatibility') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur") ;; - *'container set-environment-variables'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'connector create-or-update'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'config open-ccloud-connector-in-browser'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h automatically browser")" -- "$cur") ;; *'topic set-schema-compatibility'*'--topic') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; + *'container set-environment-variables'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + ;; + *'debug generate-diagnostics'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; + *'connector create-or-update'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + *'ec2 sync-repro-folder ec2-to-local'*'-i') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; @@ -160,11 +160,7 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; - *'container get-properties'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'tcp-proxy toggle-accept-connections'*) + *'config container-kill-all-before-run'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; @@ -172,11 +168,15 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --env --help --restore-original-values -c -h")" -- "$cur") ;; - *'ec2 sync-repro-folder ec2-to-local'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") + *'container get-properties'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'ec2 sync-repro-folder local-to-ec2'*) + *'tcp-proxy toggle-accept-connections'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + ;; + + *'ec2 sync-repro-folder ec2-to-local'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") ;; @@ -188,6 +188,10 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; + *'ec2 sync-repro-folder local-to-ec2'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") + ;; + *'connector show-config-parameters'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; @@ -196,16 +200,16 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'cleanup-cloud-resources'*'--resource') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "aws gcp azure ccloud salesforce")" -- "$cur") + *'schema get-compatibility'*'--subject') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; *'schema set-compatibility'*'--subject') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'schema get-compatibility'*'--subject') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") + *'cleanup-cloud-resources'*'--resource') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "aws gcp azure ccloud salesforce")" -- "$cur") ;; *'connector create-or-update'*'--level') @@ -220,80 +224,76 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; + *'debug flight-recorder'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + ;; + *'connector offsets get'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; + *'topic set-schema-compatibility'*'-t') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + ;; + *'topic produce'*'--compression-codec') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "gzip snappy lz4 zstd")" -- "$cur") ;; - *'debug flight-recorder'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'tcp-proxy toggle-writes-service'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") ;; - *'topic set-schema-compatibility'*'-t') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'debug enable-remote-debugging'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'container change-jdk'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'tcp-proxy toggle-writes-service'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") - ;; - *'topic get-number-records'*'--topic') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'debug enable-remote-debugging'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'tools install-vscode-extension'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'tcp-proxy toggle-writes-client'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") ;; - *'tcp-proxy break'*'--connection-id') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") + *'debug block-traffic'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'tcp-proxy toggle-reads-service'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") ;; - *'tcp-proxy delay'*'--connection-id') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") + *'topic display-consumer-offsets'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --verbose -h -v")" -- "$cur") ;; - *'debug block-traffic'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'tools install-vscode-extension'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'topic produce'*'--validate-config') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "scrub.invalid.names=true enhanced.avro.schema.support=true connect.meta.data=false object.additional.properties=false use.optional.for.nonrequired=true ignore.default.for.nullables=true generalized.sum.type.support=true enhanced.protobuf.schema.support=true generate.index.for.unions=false int.for.enums=true optional.for.nullables=true generate.struct.for.nulls=true wrapper.for.nullables=true wrapper.for.raw.primitives=false")" -- "$cur") + *'connector log-level'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'topic display-consumer-offsets'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --verbose -h -v")" -- "$cur") + *'topic produce'*'--validate-config') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "scrub.invalid.names=true enhanced.avro.schema.support=true connect.meta.data=false object.additional.properties=false use.optional.for.nonrequired=true ignore.default.for.nullables=true generalized.sum.type.support=true enhanced.protobuf.schema.support=true generate.index.for.unions=false int.for.enums=true optional.for.nullables=true generate.struct.for.nulls=true wrapper.for.nullables=true wrapper.for.raw.primitives=false")" -- "$cur") ;; - *'tcp-proxy toggle-writes-client'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") + *'tcp-proxy break'*'--connection-id') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; *'topic set-schema-compatibility'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--compatibility --help --topic --verbose -h -t -v")" -- "$cur") ;; - *'connector log-level'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") - ;; - - *'tcp-proxy toggle-reads-client'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") + *'tcp-proxy delay'*'--connection-id') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zazkia-connection-list)")" -- "$cur") ;; *'debug flight-recorder'*'--action') @@ -304,10 +304,6 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "parquet")")" -- "$cur") ;; - *'container change-jdk'*'--version') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "8 11 17 21 22")" -- "$cur") - ;; - *'debug enable-remote-debugging'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; @@ -316,23 +312,31 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'connector-plugin search-jar'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur") + *'container change-jdk'*'--version') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "8 11 17 21 22")" -- "$cur") + ;; + + *'connector snippets'*'--converter') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "avro protobuf json-schema json json-schema-enabled string bytearray")" -- "$cur") ;; *'update-version'*'--connector-jar') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type jar "$cur")")" -- "$cur") ;; - *'update-version'*'--connector-zip') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type zip "$cur")")" -- "$cur") + *'tcp-proxy toggle-reads-client'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") ;; - *'connector snippets'*'--converter') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "avro protobuf json-schema json json-schema-enabled string bytearray")" -- "$cur") + *'connector-plugin search-jar'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur") ;; - *'debug generate-diagnostics'*'-c') + *'update-version'*'--connector-zip') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type zip "$cur")")" -- "$cur") + ;; + + *'container unpause'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; @@ -340,54 +344,46 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'topic produce'*'--compatibility') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur") + *'debug generate-diagnostics'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector unpause'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'debug thread-dump'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'connector create-or-update'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'debug thread-dump'*'--container') + *'container restart'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector restart'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") - ;; - *'connector create-or-update'*'-l') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") ;; - *'container unpause'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'container restart'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'connector unpause'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'connector-plugin versions'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur") + *'topic produce'*'--compatibility') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "BACKWARD BACKWARD_TRANSITIVE FORWARD FORWARD_TRANSITIVE FULL FULL_TRANSITIVE NONE")" -- "$cur") ;; - *'connector status'*'--connector') + *'connector restart'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'connector-plugin search-jar'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--class --connector-plugin --connector-tag --help -c -h")" -- "$cur") - ;; - *'connector delete'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; + *'container resume'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + ;; + *'connector resume'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; @@ -396,20 +392,24 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "start stop")" -- "$cur") ;; - *'container resume'*'--container') + *'debug java-debug'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector update'*'--connector') + *'connector status'*'--connector') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'debug java-debug'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'connector-plugin versions'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-plugin "$cur")")" -- "$cur") ;; - *'container get-ip-addresses'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'connector update'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'connector-plugin search-jar'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--class --connector-plugin --connector-tag --help -c -h")" -- "$cur") ;; *'container get-properties'*'-c') @@ -420,60 +420,72 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'topic consume'*'--key-subject') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") + *'connector create-or-update'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --level --offsets --package --skip-automatic-connector-config --validate --verbose --wait-for-zero-lag -c -h -l -p -v")" -- "$cur") ;; - *'topic get-number-records'*'-t') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'container get-ip-addresses'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'get-jmx-metrics'*'--container') + *'container pause'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector log-level'*'--level') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") - ;; - *'debug log-level set'*'--level') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") ;; - *'connector create-or-update'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --level --offsets --package --skip-automatic-connector-config --validate --verbose --wait-for-zero-lag -c -h -l -p -v")" -- "$cur") + *'get-jmx-metrics'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector pause'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'debug heap-dump'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'tools read-avro-file'*'--file') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "avro")")" -- "$cur") ;; - *'tcp-proxy close-connection'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") + *'topic consume'*'--key-subject') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'debug heap-dump'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'connector log-level'*'--level') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") ;; - *'container pause'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'topic get-number-records'*'-t') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'container logs'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; + *'tcp-proxy close-connection'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") + ;; + + *'connector pause'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'connector stop'*'--connector') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; *'debug tcp-dump'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'ec2 create'*'--instance-type') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "c1.medium c1.xlarge c3.2xlarge c3.4xlarge c3.8xlarge c3.large c3.xlarge c4.2xlarge c4.4xlarge c4.large c4.xlarge m1.large m1.medium m1.small m1.xlarge m2.2xlarge m2.4xlarge m2.xlarge m3.2xlarge m3.large m3.medium m3.xlarge m4.10xlarge m4.2xlarge m4.4xlarge m4.large m4.xlarge t1.micro t2.large t2.medium t2.micro t2.nano t2.small t3.2xlarge")" -- "$cur") + *'connector offsets reset'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'connector-plugin versions'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector-plugin --force-refresh --help --last -c -h")" -- "$cur") + ;; + + *'container logs'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'container exec'*'--container') @@ -484,39 +496,39 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur") ;; - *'container kill'*'--container') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'ec2 create'*'--instance-type') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "c1.medium c1.xlarge c3.2xlarge c3.4xlarge c3.8xlarge c3.large c3.xlarge c4.2xlarge c4.4xlarge c4.large c4.xlarge m1.large m1.medium m1.small m1.xlarge m2.2xlarge m2.4xlarge m2.xlarge m3.2xlarge m3.large m3.medium m3.xlarge m4.10xlarge m4.2xlarge m4.4xlarge m4.large m4.xlarge t1.micro t2.large t2.medium t2.micro t2.nano t2.small t3.2xlarge")" -- "$cur") ;; - *'connector select-config'*'-c') + *'connector offsets alter'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'tcp-proxy get-connections'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") + *'config check-repo-version'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'connector-plugin versions'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector-plugin --force-refresh --help --last -c -h")" -- "$cur") + *'tcp-proxy start'*'--hostname') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'tools read-parquet-file'*'-f') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "parquet")")" -- "$cur") ;; - *'connector offsets reset'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'container kill'*'--container') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'repro bootstrap'*'--pipeline') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro --sink-only "$cur")")" -- "$cur") + *'tcp-proxy get-connections'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --help -h")" -- "$cur") ;; - *'connector stop'*'--connector') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'repro bootstrap'*'--pipeline') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro --sink-only "$cur")")" -- "$cur") ;; - *'connector offsets alter'*'-c') + *'connector select-config'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; @@ -524,23 +536,15 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "none avro avro-with-key protobuf protobuf-with-key json-schema json-schema-with-key")" -- "$cur") ;; - *'tcp-proxy start'*'--hostname') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'schema register'*'--subject') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") - ;; - - *'topic produce'*'--reference') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur") + *'topic get-number-records'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --topic -h -t")" -- "$cur") ;; - *'schema get-compatibility'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --subject --verbose -h -v")" -- "$cur") + *'run'*'--cluster-environment') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ccloud-environment-list "$cur")")" -- "$cur") ;; - *'config folder_zip_or_jar'*) + *'remove-all-docker-images'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; @@ -548,44 +552,40 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'schema set-compatibility'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--compatibility --help --subject --verbose -h -v")" -- "$cur") - ;; - *'container ssh'*'--container') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'schema set-mode'*'--subject') + *'schema register'*'--subject') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'schema get-mode'*'--subject') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") + *'schema get-compatibility'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --subject --verbose -h -v")" -- "$cur") ;; - *'debug java-debug'*'--action') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "enable disable")" -- "$cur") + *'schema set-compatibility'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--compatibility --help --subject --verbose -h -v")" -- "$cur") ;; - *'remove-all-docker-images'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'schema get-mode'*'--subject') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'topic get-number-records'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --topic -h -t")" -- "$cur") + *'schema set-mode'*'--subject') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'run'*'--cluster-environment') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ccloud-environment-list "$cur")")" -- "$cur") + *'config folder_zip_or_jar'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'connector offsets get'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'topic produce'*'--reference') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur") ;; - *'connector offsets reset'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'debug java-debug'*'--action') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "enable disable")" -- "$cur") ;; *'schema register'*'--schema') @@ -604,39 +604,39 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--force --help --resource -h")" -- "$cur") ;; - *'tools read-parquet-file'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") + *'connector select-config'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur") ;; - *'connector show-config'*'-c') + *'connector offsets get'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'connector select-config'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur") - ;; - - *'container change-jdk'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'tools read-parquet-file'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") ;; - *'debug java-debug'*'--type') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "ssl_all ssl_handshake class_loading kerberos")" -- "$cur") + *'connector offsets reset'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'tools read-avro-file'*'-f') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "avro")")" -- "$cur") + *'connector show-config'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; *'schema delete'*'--subject') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") ;; - *'debug flight-recorder'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--action --container --help -c -h")" -- "$cur") + *'tools read-avro-file'*'-f') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-specific-file-extension "$cur" --extension "avro")")" -- "$cur") ;; - *'debug block-traffic'*'-c') + *'debug java-debug'*'--type') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "ssl_all ssl_handshake class_loading kerberos")" -- "$cur") + ;; + + *'container change-jdk'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; @@ -648,11 +648,23 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur") ;; - *'debug log-level set'*'-l') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") + *'ec2 sync-repro-folder'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h ec2-to-local local-to-ec2")" -- "$cur") ;; - *'connector log-level'*'-l') + *'cleanup-cloud-details'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + ;; + + *'schema set-mode'*'--mode') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "IMPORT READONLY READWRITE")" -- "$cur") + ;; + + *'connector offsets get'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + ;; + + *'debug log-level set'*'-l') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") ;; @@ -660,47 +672,51 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur") ;; - *'connector log-level'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'debug flight-recorder'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--action --container --help -c -h")" -- "$cur") ;; - *'schema set-mode'*'--mode') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "IMPORT READONLY READWRITE")" -- "$cur") + *'debug block-traffic'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector offsets get'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'connector log-level'*'-l') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN DEBUG TRACE")" -- "$cur") ;; - *'connector show-config'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --force-rest-endpoint --help --verbose -c -h -v")" -- "$cur") + *'connector log-level'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; *'repro bootstrap'*'--file') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro "$cur")")" -- "$cur") ;; - *'cleanup-cloud-details'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'connector show-config'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --force-rest-endpoint --help --verbose -c -h -v")" -- "$cur") ;; - *'ec2 sync-repro-folder'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h ec2-to-local local-to-ec2")" -- "$cur") + *'ec2 delete'*'--instance') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-cloudformation-list $cur)")" -- "$cur") + ;; + + *'topic consume'*'--topic') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; *'tools read-avro-file'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") ;; - *'topic produce'*'--topic') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'connector show-lag'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; *'topic produce'*'--value') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur") ;; - *'topic consume'*'--topic') + *'topic produce'*'--topic') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; @@ -708,38 +724,22 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-docker-ports)")" -- "$cur") ;; - *'connector show-lag'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") - ;; - - *'ec2 delete'*'--instance') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-cloudformation-list $cur)")" -- "$cur") + *'container change-jdk'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --version -c -h")" -- "$cur") ;; *'container ssh'*'--shell') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "bash sh ksh zsh")" -- "$cur") ;; - *'container change-jdk'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --version -c -h")" -- "$cur") + *'connector unpause'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; *'connector open-docs'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --only-show-url -h")" -- "$cur") ;; - *'container restart'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'debug thread-dump'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") - ;; - - *'schema get'*'--subject') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") - ;; - *'update-version'*'--tag') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-tag-list "$cur")")" -- "$cur") ;; @@ -748,58 +748,86 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --level -c -h -l")" -- "$cur") ;; - *'debug block-traffic'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--action --container --destination --help --port -c -h")" -- "$cur") + *'connector restart'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'run'*'--cluster-region') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-kafka-region-list "$cur")")" -- "$cur") ;; *'ec2 start'*'--instance') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; - *'debug log-level get'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --package -h -p")" -- "$cur") + *'topic delete'*'--topic') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + ;; + + *'container restart'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'debug log-level set'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --level --package -h -l -p")" -- "$cur") ;; - *'run'*'--cluster-region') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-kafka-region-list "$cur")")" -- "$cur") + *'debug log-level get'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --package -h -p")" -- "$cur") ;; - *'topic delete'*'--topic') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'container unpause'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector restart'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'debug block-traffic'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--action --container --destination --help --port -c -h")" -- "$cur") ;; - *'container unpause'*'-c') + *'debug thread-dump'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector unpause'*'-c') + *'schema get'*'--subject') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-subject-list)")" -- "$cur") + ;; + + *'connector resume'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'topic alter'*'--topic') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'connector versions'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'ec2 stop'*'--instance') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + *'run'*'--connector-jar') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type jar "$cur")")" -- "$cur") ;; - *'ec2 open'*'--instance') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + *'run'*'--cluster-cloud') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "aws gcp azure")" -- "$cur") + ;; + + *'connector delete'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'debug java-debug'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'connector snippets'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--converter --dlq --help -h")" -- "$cur") ;; + *'connector show-lag'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --interval --max-wait --verbose -c -h -v")" -- "$cur") + ;; + + *'repro import'*'--file') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur") + ;; + *'connector status'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; @@ -808,123 +836,135 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --ignore-current-versions -h")" -- "$cur") ;; - *'get-docker-compose'*) + *'container kill-all'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'repro import'*'--file') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur") + *'topic alter'*'--topic') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'connector show-lag'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --interval --max-wait --verbose -c -h -v")" -- "$cur") + *'run'*'--connector-zip') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type zip "$cur")")" -- "$cur") ;; - *'connector versions'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'ec2 open'*'--instance') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; - *'connector delete'*'-c') + *'ec2 stop'*'--instance') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + ;; + + *'connector update'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'container kill-all'*) + *'get-docker-compose'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'connector resume'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'topic produce'*'--key') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur") ;; *'container resume'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'topic produce'*'--key') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-predefined-schemas "$cur")")" -- "$cur") + *'container pause'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'run'*'--connector-zip') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type zip "$cur")")" -- "$cur") + *'connector offsets'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h alter get get-offsets-request-status reset")" -- "$cur") ;; - *'debug java-debug'*'-c') + *'run'*'--cluster-name') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ccloud-cluster-list "$cur")")" -- "$cur") + ;; + + *'get-jmx-metrics'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector update'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'container unpause'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'run'*'--cluster-cloud') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "aws gcp azure")" -- "$cur") + *'run'*'--cluster-type') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "basic standard dedicated")" -- "$cur") ;; - *'run'*'--connector-jar') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-zip-or-jar-with-fzf --type jar "$cur")")" -- "$cur") + *'connector plugins'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--all --help --verbose -h -v")" -- "$cur") ;; - *'run'*'--cluster-name') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ccloud-cluster-list "$cur")")" -- "$cur") + *'connector pause'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + ;; + + *'connector restart'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; *'debug heap-dump'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'connector offsets'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h alter get get-offsets-request-status reset")" -- "$cur") + *'connector unpause'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'repro bootstrap'*'-p') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "none avro avro-with-key protobuf protobuf-with-key json-schema json-schema-with-key")" -- "$cur") + *'debug thread-dump'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'repro bootstrap'*'-f') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro "$cur")")" -- "$cur") + *'container restart'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'connector plugins'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--all --help --verbose -h -v")" -- "$cur") + *'repro bootstrap'*'-f') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf --without-repro "$cur")")" -- "$cur") ;; - *'connector pause'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'repro bootstrap'*'-p') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "none avro avro-with-key protobuf protobuf-with-key json-schema json-schema-with-key")" -- "$cur") ;; - *'connector restart'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'run'*'--environment') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "ccloud plaintext sasl-ssl sasl-plain 2way-ssl sasl-scram kraft-external-plaintext kraft-plaintext kerberos ssl_kerberos ldap-authorizer-sasl-plain ldap-sasl-plain rbac-sasl-plain")" -- "$cur") ;; - *'container pause'*'-c') + *'container exec'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'container unpause'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") + *'connector delete'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'connector unpause'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'connector update'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur") ;; - *'container restart'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") + *'config clipboard'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'get-jmx-metrics'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'connector resume'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'run'*'--cluster-type') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "basic standard dedicated")" -- "$cur") + *'connector stop'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") ;; - *'debug thread-dump'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") + *'debug tcp-dump'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'container logs'*'-c') + *'container kill'*'-c') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; @@ -932,56 +972,48 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--action --container --help --type -c -h")" -- "$cur") ;; - *'connector-plugin'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h search-jar versions")" -- "$cur") - ;; - - *'container resume'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") - ;; - *'topic describe'*'-t') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'connector delete'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'container logs'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; - *'debug tcp-dump'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'connector status'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'config clipboard'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + *'container resume'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'connector update'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help -c -h")" -- "$cur") + *'connector-plugin'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h search-jar versions")" -- "$cur") ;; - *'connector stop'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-connector-list)")" -- "$cur") + *'debug heap-dump'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --histo --live -c -h")" -- "$cur") ;; - *'connector resume'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'schema get-mode'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --subject --verbose -h -v")" -- "$cur") ;; - *'run'*'--environment') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "ccloud plaintext sasl-ssl sasl-plain 2way-ssl sasl-scram kraft-external-plaintext kraft-plaintext kerberos ssl_kerberos ldap-authorizer-sasl-plain ldap-sasl-plain rbac-sasl-plain")" -- "$cur") + *'container pause'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'container kill'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'topic consume'*'-t') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'connector status'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") + *'schema set-mode'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --mode --subject --verbose -h -v")" -- "$cur") ;; - *'container exec'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'repro bootstrap'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--custom-smt --description --file --help --pipeline -d -f -h")" -- "$cur") ;; *'container ssh'*'-s') @@ -992,112 +1024,92 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--break-service-response --connection-id --help -h")" -- "$cur") ;; - *'get-jmx-metrics'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --domain --help --open -c -d -h -o")" -- "$cur") - ;; - - *'debug log-level'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h get set")" -- "$cur") - ;; - - *'topic produce'*'-t') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") - ;; - *'tcp-proxy start'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--break-service-response --delay-service-response --help --hostname --port --service-response-corrupt --skip-automatic-connector-config --throttle-service-response -h")" -- "$cur") ;; - *'tcp-proxy delay'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --delay-service-response --help -h")" -- "$cur") + *'get-jmx-metrics'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --domain --help --open -c -d -h -o")" -- "$cur") ;; *'connector pause'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'repro bootstrap'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--custom-smt --description --file --help --pipeline -d -f -h")" -- "$cur") - ;; - - *'topic consume'*'-t') + *'topic produce'*'-t') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'container pause'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") + *'container ssh'*'-c') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") ;; *'schema register'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --id --schema --subject --verbose -h -v")" -- "$cur") ;; - *'container ssh'*'-c') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(docker ps --format '{{.Names}}')")" -- "$cur") + *'tcp-proxy delay'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connection-id --delay-service-response --help -h")" -- "$cur") ;; - *'debug heap-dump'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --histo --live -c -h")" -- "$cur") + *'debug log-level'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h get set")" -- "$cur") ;; - *'schema get-mode'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --subject --verbose -h -v")" -- "$cur") + *'update-version'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector-jar --connector-tag --connector-zip --help --tag -h")" -- "$cur") ;; - *'schema set-mode'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --mode --subject --verbose -h -v")" -- "$cur") + *'container logs'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --max-wait --open --wait-for-log -c -h -m -o -w")" -- "$cur") ;; - *'connector logs'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --lcc-id --max-wait --open --wait-for-log -h -m -o -w")" -- "$cur") + *'repro import'*'-f') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur") ;; - *'update-version'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector-jar --connector-tag --connector-zip --help --tag -h")" -- "$cur") + *'container exec'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--command --container --help --root --shell -c -h")" -- "$cur") ;; - *'topic describe'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --topic --verbose -h -t -v")" -- "$cur") + *'debug tcp-dump'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --duration --help --port -c -h")" -- "$cur") ;; *'connector stop'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--connector --help --verbose -c -h -v")" -- "$cur") ;; - *'container exec'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--command --container --help --root --shell -c -h")" -- "$cur") + *'topic describe'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --topic --verbose -h -t -v")" -- "$cur") ;; - *'container logs'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --max-wait --open --wait-for-log -c -h -m -o -w")" -- "$cur") + *'connector logs'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --lcc-id --max-wait --open --wait-for-log -h -m -o -w")" -- "$cur") ;; - *'topic delete'*'-t') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + *'container kill'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") ;; - *'repro import'*'-f') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-playground-repro-export-with-fzf "$cur")")" -- "$cur") + *'topic delete'*'-t') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") ;; - *'container kill'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help -c -h")" -- "$cur") + *'schema delete'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --id --permanent --subject --verbose --version -h -v")" -- "$cur") ;; - *'debug tcp-dump'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --duration --help --port -c -h")" -- "$cur") + *'config editor'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; *'topic produce'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--compatibility --compression-codec --consume --delete-topic --forced-key --forced-value --generate-only --headers --help --key --key-subject-name-strategy --max-nb-messages-per-batch --nb-messages --nb-partitions --no-null --producer-property --record-size --sleep-time-between-batch --tombstone --topic --validate --validate-config --value --value-subject-name-strategy --verbose -h -t -v")" -- "$cur") ;; - *'topic alter'*'-t') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") - ;; - - *'schema delete'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --id --permanent --subject --verbose --version -h -v")" -- "$cur") + *'--output-level') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN ERROR")" -- "$cur") ;; *'debug testssl'*) @@ -1112,16 +1124,16 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'config editor'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") - ;; - *'container ssh'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--container --help --shell -c -h -s")" -- "$cur") ;; - *'--output-level') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "INFO WARN ERROR")" -- "$cur") + *'topic alter'*'-t') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-topic-list)")" -- "$cur") + ;; + + *'repro export'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--all --help -h")" -- "$cur") ;; *'ec2 delete'*'-i') @@ -1132,34 +1144,34 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") ;; - *'topic delete'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --skip-delete-schema --topic --verbose -h -t -v")" -- "$cur") - ;; - *'topic create'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --nb-partitions --topic --verbose -h -t -v")" -- "$cur") ;; - *'repro export'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--all --help -h")" -- "$cur") + *'topic delete'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --skip-delete-schema --topic --verbose -h -t -v")" -- "$cur") ;; *'switch-back'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'ec2 start'*'-i') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") - ;; - *'topic alter'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --topic --verbose -h -t -v")" -- "$cur") ;; + *'ec2 start'*'-i') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") + ;; + *'topic list'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; + *'open'*'--file') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-any-file-with-fzf "$cur")")" -- "$cur") + ;; + *'ec2 stop'*'-i') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; @@ -1168,34 +1180,18 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance-type --size --suffix -h")" -- "$cur") ;; - *'schema get'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--deleted --help --id --subject --verbose -h -v")" -- "$cur") - ;; - *'ec2 delete'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") ;; - *'open'*'--file') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-any-file-with-fzf "$cur")")" -- "$cur") + *'schema get'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--deleted --help --id --subject --verbose -h -v")" -- "$cur") ;; *'ec2 open'*'-i') while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-ec2-instance-list $cur)")" -- "$cur") ;; - *'container'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h change-jdk exec get-ip-addresses get-properties kill kill-all logs pause recreate restart resume set-environment-variables ssh unpause")" -- "$cur") - ;; - - *'ec2 start'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") - ;; - - *'run'*'--file') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf "$cur")")" -- "$cur") - ;; - *'tcp-proxy'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h break close-all-connection-with-error close-connection delay get-connections start toggle-accept-connections toggle-reads-client toggle-reads-service toggle-writes-client toggle-writes-service")" -- "$cur") ;; @@ -1204,18 +1200,30 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h create-or-update delete log-level logs offsets open-ccloud-connector-in-browser open-docs pause plugins restart resume select-config show-config show-config-parameters show-lag snippets status stop unpause update versions")" -- "$cur") ;; + *'container'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h change-jdk exec get-ip-addresses get-properties kill kill-all logs pause recreate restart resume set-environment-variables ssh unpause")" -- "$cur") + ;; + *'open-docs'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --only-show-url -h")" -- "$cur") ;; - *'run'*'--tag') - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-tag-list "$cur")")" -- "$cur") + *'ec2 start'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help --instance -h -i")" -- "$cur") + ;; + + *'run'*'--file') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-examples-list-with-fzf "$cur")")" -- "$cur") ;; *'ec2 open'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--disable-sync-repro-folder --help --instance -h -i")" -- "$cur") ;; + *'run'*'--tag') + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "$(playground get-tag-list "$cur")")" -- "$cur") + ;; + *'ec2 list'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; @@ -1228,16 +1236,8 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'re-run'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") - ;; - *'config'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h clipboard editor folder_zip_or_jar open-ccloud-connector-in-browser")" -- "$cur") - ;; - - *'schema'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h delete get get-compatibility get-mode register set-compatibility set-mode")" -- "$cur") + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h check-repo-version clipboard container-kill-all-before-run editor folder_zip_or_jar open-ccloud-connector-in-browser")" -- "$cur") ;; *'open'*'-f') @@ -1248,8 +1248,16 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; - *'topic'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h alter consume create delete describe display-consumer-offsets get-number-records list produce set-schema-compatibility")" -- "$cur") + *'re-run'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") + ;; + + *'schema'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h delete get get-compatibility get-mode register set-compatibility set-mode")" -- "$cur") + ;; + + *'tools'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h install-vscode-extension read-avro-file read-parquet-file")" -- "$cur") ;; *'run'*'-f') @@ -1260,22 +1268,22 @@ _playground_completions() { while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h block-traffic enable-remote-debugging flight-recorder generate-diagnostics heap-dump java-debug log-level tcp-dump testssl thread-dump")" -- "$cur") ;; - *'tools'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h install-vscode-extension read-avro-file read-parquet-file")" -- "$cur") - ;; - *'repro'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h bootstrap export import")" -- "$cur") ;; - *'open'*) - while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") + *'topic'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h alter consume create delete describe display-consumer-offsets get-number-records list produce set-schema-compatibility")" -- "$cur") ;; *'stop'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; + *'open'*) + while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--file --help -f -h")" -- "$cur") + ;; + *'help'*) while read -r; do COMPREPLY+=("$REPLY"); done < <(compgen -W "$(_playground_completions_filter "--help -h")" -- "$cur") ;; diff --git a/scripts/cli/confluent-hub-plugin-list.txt b/scripts/cli/confluent-hub-plugin-list.txt index 1f1ea7130..6b9fb060a 100644 --- a/scripts/cli/confluent-hub-plugin-list.txt +++ b/scripts/cli/confluent-hub-plugin-list.txt @@ -146,6 +146,7 @@ jcustenborder/kafka-connect-redis jcustenborder/kafka-connect-spooldir jcustenborder/kafka-connect-transform-common jcustenborder/kafka-connect-twitter +jrndio/jr-source-connector juxt/kafka-connect-crux kaliy/kafka-connect-rss kategmbh/kafka-adapter-for-sap-process-orchestration diff --git a/scripts/cli/playground b/scripts/cli/playground index da51e1959..03f270a3b 100755 --- a/scripts/cli/playground +++ b/scripts/cli/playground @@ -1129,6 +1129,8 @@ playground_config_usage() { printf " %s šŸ“‚ list of folders where to search for zip or jar\n" "$(green "folder_zip_or_jar") " printf " %s copy to clipboard connector config (only working on MacOS)\n" "$(green "clipboard") " printf " %s when running a fully managed connector example, it opens the connector in browser\n" "$(green "open-ccloud-connector-in-browser")" + printf " %s when running an example, always call playground container kill-all first. If not set, it will call playground stop instead.\n" "$(green "container-kill-all-before-run") " + printf " %s when running an example, always check if repo version is older than 3 days, if disabled, it will skip this check.\n" "$(green "check-repo-version") " echo # :command.long_usage @@ -1452,11 +1454,93 @@ playground_config_open_ccloud_connector_in_browser_browser_usage() { fi } +# :command.usage +playground_config_container_kill_all_before_run_usage() { + if [[ -n $long_usage ]]; then + printf "playground config container-kill-all-before-run\n\n" + printf " when running an example, always call playground container kill-all first. If\n not set, it will call playground stop instead.\n\n" + else + printf "playground config container-kill-all-before-run - when running an example, always call playground container kill-all first. If not set, it will call playground stop instead.\n\n" + fi + + printf "%s\n" "$(bold "== Usage ==")" + printf " playground config container-kill-all-before-run [ENABLED]\n" + printf " playground config container-kill-all-before-run --help | -h\n" + echo + + # :command.long_usage + if [[ -n "$long_usage" ]]; then + printf "%s\n" "$(bold "== Options ==")" + + # :command.usage_fixed_flags + printf " %s\n" "$(magenta "--help, -h")" + printf " Show this help\n" + echo + + # :command.usage_args + printf "%s\n" "$(bold "== Arguments ==")" + + # :argument.usage + printf " %s\n" "$(blue "ENABLED")" + printf "\n" + printf " %s\n" "Default: true" + echo + + # :command.usage_examples + printf "%s\n" "$(bold "Examples")" + printf " playground config container-kill-all-before-run false\n" + printf " playground config container-kill-all-before-run true\n" + echo + + fi +} + +# :command.usage +playground_config_check_repo_version_usage() { + if [[ -n $long_usage ]]; then + printf "playground config check-repo-version\n\n" + printf " when running an example, always check if repo version is older than 3 days, if\n disabled, it will skip this check.\n\n" + else + printf "playground config check-repo-version - when running an example, always check if repo version is older than 3 days, if disabled, it will skip this check.\n\n" + fi + + printf "%s\n" "$(bold "== Usage ==")" + printf " playground config check-repo-version [ENABLED]\n" + printf " playground config check-repo-version --help | -h\n" + echo + + # :command.long_usage + if [[ -n "$long_usage" ]]; then + printf "%s\n" "$(bold "== Options ==")" + + # :command.usage_fixed_flags + printf " %s\n" "$(magenta "--help, -h")" + printf " Show this help\n" + echo + + # :command.usage_args + printf "%s\n" "$(bold "== Arguments ==")" + + # :argument.usage + printf " %s\n" "$(blue "ENABLED")" + printf "\n" + printf " %s\n" "Default: true" + echo + + # :command.usage_examples + printf "%s\n" "$(bold "Examples")" + printf " playground config check-repo-version false\n" + printf " playground config check-repo-version true\n" + echo + + fi +} + # :command.usage playground_run_usage() { if [[ -n $long_usage ]]; then printf "playground run\n\n" - printf " šŸ•¹ļø Run any example !\n \n šŸ”„ It start an interactive mode where you'll be fully guided !\n \n \n ā›… When running Confluent Cloud (ccloud) example:\n \n All you have to do is to be already logged in with confluent CLI.\n \n By default, a new Confluent Cloud environment with a Cluster will be\n created.\n \n You can configure the new cluster by setting:\n \n --cluster-type (or CLUSTER_TYPE environment variable): The type of cluster\n (possible values: basic, standard and dedicated, default basic)\n --cluster-cloud (or CLUSTER_CLOUD environment variable): The Cloud provider\n (possible values: aws, gcp and azure, default aws)\n --cluster-region (or CLUSTER_REGION environment variable): The Cloud region\n (use confluent kafka region list to get the list, default eu-west-2 for aws,\n westeurope for azure and europe-west2 for gcp)\n --cluster-environment (or ENVIRONMENT environment variable) (optional): The\n environment id where want your new cluster (example: txxxxx)\n \n In case you want to use your own existing cluster, you need to setup, in\n addition to previous ones:\n \n --cluster-name (or CLUSTER_NAME environment variable): The cluster name\n --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key\n and secret to use, it should be separated with colon (example:\n :)\n --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment\n variable) (optional, if not set, new one will be created): The Schema Registry\n api key and secret to use, it should be separated with colon (example:\n :)\n \n ā— this command will kill all containers using playground container kill-all\n\n" + printf " šŸ•¹ļø Run any example !\n \n šŸ”„ It start an interactive mode where you'll be fully guided !\n \n \n ā›… When running Confluent Cloud (ccloud) example:\n \n All you have to do is to be already logged in with confluent CLI.\n \n By default, a new Confluent Cloud environment with a Cluster will be\n created.\n \n You can configure the new cluster by setting:\n \n --cluster-type (or CLUSTER_TYPE environment variable): The type of cluster\n (possible values: basic, standard and dedicated, default basic)\n --cluster-cloud (or CLUSTER_CLOUD environment variable): The Cloud provider\n (possible values: aws, gcp and azure, default aws)\n --cluster-region (or CLUSTER_REGION environment variable): The Cloud region\n (use confluent kafka region list to get the list, default eu-west-2 for aws,\n westeurope for azure and europe-west2 for gcp)\n --cluster-environment (or ENVIRONMENT environment variable) (optional): The\n environment id where want your new cluster (example: txxxxx)\n \n In case you want to use your own existing cluster, you need to setup, in\n addition to previous ones:\n \n --cluster-name (or CLUSTER_NAME environment variable): The cluster name\n --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key\n and secret to use, it should be separated with colon (example:\n :)\n --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment\n variable) (optional, if not set, new one will be created): The Schema Registry\n api key and secret to use, it should be separated with colon (example:\n :)\n \n ā— this command will kill all containers using \"playground container kill-all\",\n you can disable this by running \"playground config\n container-kill-all-before-run false\"\n\n" else printf "playground run - šŸ•¹ļø Run any example !\n\n" fi @@ -8196,7 +8280,7 @@ function maybe_create_image() export CONNECT_USER="appuser" if [ `uname -m` = "arm64" ] then - CONNECT_3RDPARTY_INSTALL="if [ ! -f /tmp/done ]; then yum -y install --disablerepo='Confluent*' bind-utils openssl unzip findutils net-tools nc jq which iptables libmnl krb5-workstation krb5-libs vim && yum clean all && rm -rf /var/cache/yum && rpm -i --nosignature https://koji.mbox.centos.org/kojifiles/packages/tcpdump/4.9.3/3.el8/aarch64/tcpdump-4.9.3-3.el8.aarch64.rpm && touch /tmp/done; fi" + CONNECT_3RDPARTY_INSTALL="if [ ! -f /tmp/done ]; then yum -y install --disablerepo='Confluent*' bind-utils openssl unzip findutils net-tools nc jq which iptables libmnl krb5-workstation krb5-libs vim && yum clean all && rm -rf /var/cache/yum && rpm -i --nosignature https://yum.oracle.com/repo/OracleLinux/OL8/appstream/aarch64/getPackage/tcpdump-4.9.3-3.el8.aarch64.rpm && touch /tmp/done; fi" else CONNECT_3RDPARTY_INSTALL="if [ ! -f /tmp/done ]; then curl https://download.rockylinux.org/pub/rocky/8/AppStream/x86_64/kickstart/Packages/t/tcpdump-4.9.3-5.el8.x86_64.rpm -o tcpdump-4.9.3-1.el8.x86_64.rpm && rpm -Uvh tcpdump-4.9.3-1.el8.x86_64.rpm && yum -y install --disablerepo='Confluent*' bind-utils openssl unzip findutils net-tools nc jq which iptables libmnl krb5-workstation krb5-libs vim && yum clean all && rm -rf /var/cache/yum && touch /tmp/done; fi" fi @@ -8386,29 +8470,38 @@ function check_bash_version() { } function check_playground_version() { - set +e - X=3 - git fetch - latest_commit_date=$(git log -1 --format=%cd --date=short) - remote_commit_date=$(git log -1 --format=%cd --date=short origin/master) - - if [[ "$OSTYPE" == "darwin"* ]] + check_repo_version=$(playground config get check-repo-version) + if [ "$check_repo_version" == "" ] then - latest_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$latest_commit_date" +%s) - remote_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$remote_commit_date" +%s) - else - latest_commit_date_seconds=$(date -d "$latest_commit_date" +%s) - remote_commit_date_seconds=$(date -d "$remote_commit_date" +%s) + playground config set check-repo-version true fi - difference=$(( (remote_commit_date_seconds - latest_commit_date_seconds) / (60*60*24) )) - - if [ $difference -gt $X ] + if [ "$check_repo_version" == "true" ] || [ "$check_repo_version" == "" ] then - logwarn "šŸ„¶ The current repo version is older than $X days ($difference days), please refresh your version using git pull !" - check_if_continue + set +e + X=3 + git fetch + latest_commit_date=$(git log -1 --format=%cd --date=short) + remote_commit_date=$(git log -1 --format=%cd --date=short origin/master) + + if [[ "$OSTYPE" == "darwin"* ]] + then + latest_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$latest_commit_date" +%s) + remote_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$remote_commit_date" +%s) + else + latest_commit_date_seconds=$(date -d "$latest_commit_date" +%s) + remote_commit_date_seconds=$(date -d "$remote_commit_date" +%s) + fi + + difference=$(( (remote_commit_date_seconds - latest_commit_date_seconds) / (60*60*24) )) + + if [ $difference -gt $X ] + then + logwarn "šŸ„¶ The current repo version is older than $X days ($difference days), please refresh your version using git pull ! (disable with 'playground config check-repo-version false')" + check_if_continue + fi + set -e fi - set -e } function set_profiles() { @@ -13334,6 +13427,20 @@ playground_config_open_ccloud_connector_in_browser_browser_command() { playground config set open-ccloud-connector-in-browser.browser "${args[browser]}" } +# :command.function +playground_config_container_kill_all_before_run_command() { + # src/commands/config/container-kill-all-before-run.sh + log "šŸ“‹ configuring container-kill-all-before-run with ${args[enabled]}" + playground config set container-kill-all-before-run "${args[enabled]}" +} + +# :command.function +playground_config_check_repo_version_command() { + # src/commands/config/check-repo-version.sh + log "šŸ“‹ configuring check-repo-version with ${args[enabled]}" + playground config set check-repo-version "${args[enabled]}" +} + # :command.function playground_run_command() { # src/commands/run.sh @@ -13410,6 +13517,22 @@ playground_run_command() { verify_installed "confluent" fi + set +e + container_kill_all_before_run=$(playground config get container-kill-all-before-run) + if [ "$container_kill_all_before_run" == "" ] + then + playground config set container-kill-all-before-run true + fi + + if [ "$container_kill_all_before_run" == "true" ] || [ "$container_kill_all_before_run" == "" ] + then + log "šŸ’€ kill all docker containers (disable with 'playground config container-kill-all-before-run false')" + playground container kill-all + else + playground stop + fi + set -e + playground state set run.test_file "$test_file" test_file_directory="$(dirname "${test_file}")" filename=$(basename -- "$test_file") @@ -14792,9 +14915,7 @@ playground_run_command() { log "šŸš€ Running example without any flags" fi fi - set +e - playground container kill-all - set -e + playground state set run.connector_type "$(get_connector_type | tr -d '\n')" playground state set run.test_file "$test_file" echo "" >> "$root_folder/playground-run-history" @@ -14811,7 +14932,7 @@ playground_run_command() { if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then echo "playground run -f $test_file $flag_list" | pbcopy - log "šŸ“‹ command to run again example has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ command to run again example has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi @@ -14965,7 +15086,19 @@ playground_start_environment_command() { test_file_directory="$(dirname "${test_file}")" set +e - playground container kill-all + container_kill_all_before_run=$(playground config get container-kill-all-before-run) + if [ "$container_kill_all_before_run" == "" ] + then + playground config set container-kill-all-before-run true + fi + + if [ "$container_kill_all_before_run" == "true" ] || [ "$container_kill_all_before_run" == "" ] + then + log "šŸ’€ kill all docker containers (disable with 'playground config container-kill-all-before-run false')" + playground container kill-all + else + playground stop + fi set -e if [[ -n "$wait_for_control_center" ]] @@ -17412,7 +17545,7 @@ EOF if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then echo "playground run -f $repro_dir/$repro_test_filename"| pbcopy - log "šŸ“‹ command to run generated example has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ command to run generated example has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi @@ -17463,6 +17596,7 @@ playground_get_docker_compose_command() { fi echo "$docker_command" > /tmp/tmp sed -e "s|up -d|config|g" \ + -e "s|--quiet-pull||g" \ /tmp/tmp > /tmp/playground-command-config bash /tmp/playground-command-config @@ -19140,7 +19274,7 @@ playground_container_get_ip_addresses_command() { # :command.function playground_container_kill_all_command() { # src/commands/container/kill-all.sh - log "šŸ’€ Kill all docker containers" + log "šŸ’€ kill all docker containers" docker rm -f $(docker ps -qa) > /dev/null 2>&1 } @@ -23243,7 +23377,7 @@ playground_connector_show_config_command() { echo "EOF" >> $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi else @@ -23289,7 +23423,7 @@ playground_connector_show_config_command() { echo "EOF" >> $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi @@ -23614,7 +23748,7 @@ playground_connector_select_config_command() { echo "$res" > $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi done @@ -23788,7 +23922,7 @@ playground_connector_snippets_command() { if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then cat $clipboard_file | pbcopy - log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi @@ -24270,7 +24404,7 @@ playground_connector_create_or_update_command() { echo "EOF" >> $tmp_dir_clipboard/tmp cat $tmp_dir_clipboard/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi @@ -27310,6 +27444,20 @@ playground_config_parse_requirements() { shift $# ;; + container-kill-all-before-run) + action="container-kill-all-before-run" + shift + playground_config_container_kill_all_before_run_parse_requirements "$@" + shift $# + ;; + + check-repo-version) + action="check-repo-version" + shift + playground_config_check_repo_version_parse_requirements "$@" + shift $# + ;; + # :command.command_fallback "") playground_config_usage >&2 @@ -27903,6 +28051,112 @@ playground_config_open_ccloud_connector_in_browser_browser_parse_requirements() } +# :command.parse_requirements +playground_config_container_kill_all_before_run_parse_requirements() { + # :command.fixed_flags_filter + while [[ $# -gt 0 ]]; do + case "${1:-}" in + --help | -h) + long_usage=yes + playground_config_container_kill_all_before_run_usage + exit + ;; + + *) + break + ;; + + esac + done + + # :command.command_filter + action="config container-kill-all-before-run" + + # :command.parse_requirements_while + while [[ $# -gt 0 ]]; do + key="$1" + case "$key" in + + -?*) + printf "invalid option: %s\n" "$key" >&2 + exit 1 + ;; + + *) + # :command.parse_requirements_case + # :command.parse_requirements_case_simple + # :argument.case + if [[ -z ${args['enabled']+x} ]]; then + args['enabled']=$1 + shift + else + printf "invalid argument: %s\n" "$key" >&2 + exit 1 + fi + + ;; + + esac + done + + # :command.default_assignments + [[ -n ${args['enabled']:-} ]] || args['enabled']="true" + +} + +# :command.parse_requirements +playground_config_check_repo_version_parse_requirements() { + # :command.fixed_flags_filter + while [[ $# -gt 0 ]]; do + case "${1:-}" in + --help | -h) + long_usage=yes + playground_config_check_repo_version_usage + exit + ;; + + *) + break + ;; + + esac + done + + # :command.command_filter + action="config check-repo-version" + + # :command.parse_requirements_while + while [[ $# -gt 0 ]]; do + key="$1" + case "$key" in + + -?*) + printf "invalid option: %s\n" "$key" >&2 + exit 1 + ;; + + *) + # :command.parse_requirements_case + # :command.parse_requirements_case_simple + # :argument.case + if [[ -z ${args['enabled']+x} ]]; then + args['enabled']=$1 + shift + else + printf "invalid argument: %s\n" "$key" >&2 + exit 1 + fi + + ;; + + esac + done + + # :command.default_assignments + [[ -n ${args['enabled']:-} ]] || args['enabled']="true" + +} + # :command.parse_requirements playground_run_parse_requirements() { # :command.fixed_flags_filter @@ -38632,6 +38886,8 @@ run() { "config open-ccloud-connector-in-browser") playground_config_open_ccloud_connector_in_browser_command ;; "config open-ccloud-connector-in-browser automatically") playground_config_open_ccloud_connector_in_browser_automatically_command ;; "config open-ccloud-connector-in-browser browser") playground_config_open_ccloud_connector_in_browser_browser_command ;; + "config container-kill-all-before-run") playground_config_container_kill_all_before_run_command ;; + "config check-repo-version") playground_config_check_repo_version_command ;; "run") playground_run_command ;; "re-run") playground_re_run_command ;; "history") playground_history_command ;; diff --git a/scripts/cli/playground.json b/scripts/cli/playground.json index 102ae3bb9..e89490082 100644 --- a/scripts/cli/playground.json +++ b/scripts/cli/playground.json @@ -48,6 +48,18 @@ "description": "when running a fully managed connector example, it opens the connector in browser\n \n", "usage": "playground config open-ccloud-connector-in-browser COMMAND", "options": [] + }, + { + "name": "container-kill-all-before-run", + "description": "when running an example, always call playground container kill-all first. If not set, it will call playground stop instead.\n \n", + "usage": "playground config container-kill-all-before-run [ENABLED]", + "options": [] + }, + { + "name": "check-repo-version", + "description": "when running an example, always check if repo version is older than 3 days, if disabled, it will skip this check.\n \n", + "usage": "playground config check-repo-version [ENABLED]", + "options": [] } ] }, @@ -73,7 +85,7 @@ }, { "name": "run", - "description": "šŸ•¹ļø Run any example !\n\nšŸ”„ It start an interactive mode where you'll be fully guided !\n\n\nā›… When running Confluent Cloud (ccloud) example:\n\n All you have to do is to be already logged in with confluent CLI.\n\n By default, a new Confluent Cloud environment with a Cluster will be created.\n\n You can configure the new cluster by setting:\n\n --cluster-type (or CLUSTER_TYPE environment variable): The type of cluster (possible values: basic, standard and dedicated, default basic)\n --cluster-cloud (or CLUSTER_CLOUD environment variable): The Cloud provider (possible values: aws, gcp and azure, default aws)\n --cluster-region (or CLUSTER_REGION environment variable): The Cloud region (use confluent kafka region list to get the list, default eu-west-2 for aws, westeurope for azure and europe-west2 for gcp)\n --cluster-environment (or ENVIRONMENT environment variable) (optional): The environment id where want your new cluster (example: txxxxx) \n\n In case you want to use your own existing cluster, you need to setup, in addition to previous ones:\n\n --cluster-name (or CLUSTER_NAME environment variable): The cluster name\n --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key and secret to use, it should be separated with colon (example: :)\n --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment variable) (optional, if not set, new one will be created): The Schema Registry api key and secret to use, it should be separated with colon (example: :)\n\nā— this command will kill all containers using playground container kill-all\n", + "description": "šŸ•¹ļø Run any example !\n\nšŸ”„ It start an interactive mode where you'll be fully guided !\n\n\nā›… When running Confluent Cloud (ccloud) example:\n\n All you have to do is to be already logged in with confluent CLI.\n\n By default, a new Confluent Cloud environment with a Cluster will be created.\n\n You can configure the new cluster by setting:\n\n --cluster-type (or CLUSTER_TYPE environment variable): The type of cluster (possible values: basic, standard and dedicated, default basic)\n --cluster-cloud (or CLUSTER_CLOUD environment variable): The Cloud provider (possible values: aws, gcp and azure, default aws)\n --cluster-region (or CLUSTER_REGION environment variable): The Cloud region (use confluent kafka region list to get the list, default eu-west-2 for aws, westeurope for azure and europe-west2 for gcp)\n --cluster-environment (or ENVIRONMENT environment variable) (optional): The environment id where want your new cluster (example: txxxxx) \n\n In case you want to use your own existing cluster, you need to setup, in addition to previous ones:\n\n --cluster-name (or CLUSTER_NAME environment variable): The cluster name\n --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key and secret to use, it should be separated with colon (example: :)\n --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment variable) (optional, if not set, new one will be created): The Schema Registry api key and secret to use, it should be separated with colon (example: :)\n\nā— this command will kill all containers using \"playground container kill-all\", you can disable this by running \"playground config container-kill-all-before-run false\"\n", "usage": "playground run [OPTIONS]", "options": [ { diff --git a/scripts/cli/playground.yaml b/scripts/cli/playground.yaml index f678fdac7..a8ed108bc 100644 --- a/scripts/cli/playground.yaml +++ b/scripts/cli/playground.yaml @@ -49,6 +49,18 @@ subcommands: usage: playground config open-ccloud-connector-in-browser COMMAND options: [] + - name: container-kill-all-before-run + description: | + when running an example, always call playground container kill-all first. If not set, it will call playground stop instead. + + usage: playground config container-kill-all-before-run [ENABLED] + options: [] + - name: check-repo-version + description: | + when running an example, always check if repo version is older than 3 days, if disabled, it will skip this check. + + usage: playground config check-repo-version [ENABLED] + options: [] - name: open-ccloud-connector-in-browser description: | when running a fully managed connector example, it opens the connector in browser @@ -92,7 +104,7 @@ subcommands: --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key and secret to use, it should be separated with colon (example: :) --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment variable) (optional, if not set, new one will be created): The Schema Registry api key and secret to use, it should be separated with colon (example: :) - ā— this command will kill all containers using playground container kill-all + ā— this command will kill all containers using "playground container kill-all", you can disable this by running "playground config container-kill-all-before-run false" usage: playground run [OPTIONS] options: - names: diff --git a/scripts/cli/src/bashly.yml b/scripts/cli/src/bashly.yml index cb8d03c03..c8a5ebfbc 100644 --- a/scripts/cli/src/bashly.yml +++ b/scripts/cli/src/bashly.yml @@ -382,6 +382,29 @@ commands: examples: - playground config open-ccloud-connector-in-browser browser Safari + - name: container-kill-all-before-run + help: | + when running an example, always call playground container kill-all first. If not set, it will call playground stop instead. + args: + - name: enabled + required: false + default: "true" + examples: + - playground config container-kill-all-before-run false + - playground config container-kill-all-before-run true + + - name: check-repo-version + help: | + when running an example, always check if repo version is older than 3 days, if disabled, it will skip this check. + args: + - name: enabled + required: false + default: "true" + examples: + - playground config check-repo-version false + - playground config check-repo-version true + + - name: run group: Run dependencies: @@ -411,7 +434,7 @@ commands: --cluster-creds (or CLUSTER_CREDS environment variable): The Kafka api key and secret to use, it should be separated with colon (example: :) --cluster-schema-registry-creds (or SCHEMA_REGISTRY_CREDS environment variable) (optional, if not set, new one will be created): The Schema Registry api key and secret to use, it should be separated with colon (example: :) - ā— this command will kill all containers using playground container kill-all + ā— this command will kill all containers using "playground container kill-all", you can disable this by running "playground config container-kill-all-before-run false" flags: - &environment-run diff --git a/scripts/cli/src/commands/config/check-repo-version.sh b/scripts/cli/src/commands/config/check-repo-version.sh new file mode 100644 index 000000000..ecdbee1da --- /dev/null +++ b/scripts/cli/src/commands/config/check-repo-version.sh @@ -0,0 +1,2 @@ +log "šŸ“‹ configuring check-repo-version with ${args[enabled]}" +playground config set check-repo-version "${args[enabled]}" \ No newline at end of file diff --git a/scripts/cli/src/commands/config/container-kill-all-before-run.sh b/scripts/cli/src/commands/config/container-kill-all-before-run.sh new file mode 100644 index 000000000..751508406 --- /dev/null +++ b/scripts/cli/src/commands/config/container-kill-all-before-run.sh @@ -0,0 +1,2 @@ +log "šŸ“‹ configuring container-kill-all-before-run with ${args[enabled]}" +playground config set container-kill-all-before-run "${args[enabled]}" \ No newline at end of file diff --git a/scripts/cli/src/commands/connector/create-or-update.sh b/scripts/cli/src/commands/connector/create-or-update.sh index 818c5b6f0..da281d6d1 100644 --- a/scripts/cli/src/commands/connector/create-or-update.sh +++ b/scripts/cli/src/commands/connector/create-or-update.sh @@ -200,7 +200,7 @@ then echo "EOF" >> $tmp_dir_clipboard/tmp cat $tmp_dir_clipboard/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi diff --git a/scripts/cli/src/commands/connector/select-config.sh b/scripts/cli/src/commands/connector/select-config.sh index fdfbb491c..1d7d78a09 100644 --- a/scripts/cli/src/commands/connector/select-config.sh +++ b/scripts/cli/src/commands/connector/select-config.sh @@ -67,7 +67,7 @@ do echo "$res" > $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi done \ No newline at end of file diff --git a/scripts/cli/src/commands/connector/show-config.sh b/scripts/cli/src/commands/connector/show-config.sh index dd4858141..cda26bd09 100644 --- a/scripts/cli/src/commands/connector/show-config.sh +++ b/scripts/cli/src/commands/connector/show-config.sh @@ -62,7 +62,7 @@ do echo "EOF" >> $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi else @@ -108,7 +108,7 @@ do echo "EOF" >> $tmp_dir/tmp cat $tmp_dir/tmp | pbcopy - log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ $connector_type connector config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi diff --git a/scripts/cli/src/commands/connector/snippets.sh b/scripts/cli/src/commands/connector/snippets.sh index f1c786f2c..81cac87e9 100644 --- a/scripts/cli/src/commands/connector/snippets.sh +++ b/scripts/cli/src/commands/connector/snippets.sh @@ -163,7 +163,7 @@ then if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then cat $clipboard_file | pbcopy - log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ config has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi fi diff --git a/scripts/cli/src/commands/container/kill-all.sh b/scripts/cli/src/commands/container/kill-all.sh index 2fec3f6b4..a1fd23c0f 100644 --- a/scripts/cli/src/commands/container/kill-all.sh +++ b/scripts/cli/src/commands/container/kill-all.sh @@ -1,2 +1,2 @@ -log "šŸ’€ Kill all docker containers" +log "šŸ’€ kill all docker containers" docker rm -f $(docker ps -qa) > /dev/null 2>&1 \ No newline at end of file diff --git a/scripts/cli/src/commands/get-docker-compose.sh b/scripts/cli/src/commands/get-docker-compose.sh index 5d046f1b7..4e5abdd05 100644 --- a/scripts/cli/src/commands/get-docker-compose.sh +++ b/scripts/cli/src/commands/get-docker-compose.sh @@ -11,6 +11,7 @@ then fi echo "$docker_command" > /tmp/tmp sed -e "s|up -d|config|g" \ + -e "s|--quiet-pull||g" \ /tmp/tmp > /tmp/playground-command-config bash /tmp/playground-command-config \ No newline at end of file diff --git a/scripts/cli/src/commands/repro/bootstrap.sh b/scripts/cli/src/commands/repro/bootstrap.sh index 51691e7c5..f27e051da 100644 --- a/scripts/cli/src/commands/repro/bootstrap.sh +++ b/scripts/cli/src/commands/repro/bootstrap.sh @@ -1290,7 +1290,7 @@ then if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then echo "playground run -f $repro_dir/$repro_test_filename"| pbcopy - log "šŸ“‹ command to run generated example has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ command to run generated example has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi diff --git a/scripts/cli/src/commands/run.sh b/scripts/cli/src/commands/run.sh index d842175a2..65d75c417 100644 --- a/scripts/cli/src/commands/run.sh +++ b/scripts/cli/src/commands/run.sh @@ -71,6 +71,22 @@ then verify_installed "confluent" fi +set +e +container_kill_all_before_run=$(playground config get container-kill-all-before-run) +if [ "$container_kill_all_before_run" == "" ] +then + playground config set container-kill-all-before-run true +fi + +if [ "$container_kill_all_before_run" == "true" ] || [ "$container_kill_all_before_run" == "" ] +then + log "šŸ’€ kill all docker containers (disable with 'playground config container-kill-all-before-run false')" + playground container kill-all +else + playground stop +fi +set -e + playground state set run.test_file "$test_file" test_file_directory="$(dirname "${test_file}")" filename=$(basename -- "$test_file") @@ -1442,9 +1458,7 @@ else log "šŸš€ Running example without any flags" fi fi -set +e -playground container kill-all -set -e + playground state set run.connector_type "$(get_connector_type | tr -d '\n')" playground state set run.test_file "$test_file" echo "" >> "$root_folder/playground-run-history" @@ -1461,7 +1475,7 @@ then if [ "$clipboard" == "true" ] || [ "$clipboard" == "" ] then echo "playground run -f $test_file $flag_list" | pbcopy - log "šŸ“‹ command to run again example has been copied to the clipboard (disable with 'playground config set clipboard false')" + log "šŸ“‹ command to run again example has been copied to the clipboard (disable with 'playground config clipboard false')" fi fi diff --git a/scripts/cli/src/commands/start-environment.sh b/scripts/cli/src/commands/start-environment.sh index 01c334cbd..56c8d7e74 100644 --- a/scripts/cli/src/commands/start-environment.sh +++ b/scripts/cli/src/commands/start-environment.sh @@ -13,7 +13,19 @@ fi test_file_directory="$(dirname "${test_file}")" set +e -playground container kill-all +container_kill_all_before_run=$(playground config get container-kill-all-before-run) +if [ "$container_kill_all_before_run" == "" ] +then + playground config set container-kill-all-before-run true +fi + +if [ "$container_kill_all_before_run" == "true" ] || [ "$container_kill_all_before_run" == "" ] +then + log "šŸ’€ kill all docker containers (disable with 'playground config container-kill-all-before-run false')" + playground container kill-all +else + playground stop +fi set -e if [[ -n "$wait_for_control_center" ]] diff --git a/scripts/cli/src/lib/utils_function.sh b/scripts/cli/src/lib/utils_function.sh index 135db55e8..13618e3e3 100644 --- a/scripts/cli/src/lib/utils_function.sh +++ b/scripts/cli/src/lib/utils_function.sh @@ -445,29 +445,38 @@ function check_bash_version() { } function check_playground_version() { - set +e - X=3 - git fetch - latest_commit_date=$(git log -1 --format=%cd --date=short) - remote_commit_date=$(git log -1 --format=%cd --date=short origin/master) - - if [[ "$OSTYPE" == "darwin"* ]] + check_repo_version=$(playground config get check-repo-version) + if [ "$check_repo_version" == "" ] then - latest_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$latest_commit_date" +%s) - remote_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$remote_commit_date" +%s) - else - latest_commit_date_seconds=$(date -d "$latest_commit_date" +%s) - remote_commit_date_seconds=$(date -d "$remote_commit_date" +%s) + playground config set check-repo-version true fi - difference=$(( (remote_commit_date_seconds - latest_commit_date_seconds) / (60*60*24) )) - - if [ $difference -gt $X ] + if [ "$check_repo_version" == "true" ] || [ "$check_repo_version" == "" ] then - logwarn "šŸ„¶ The current repo version is older than $X days ($difference days), please refresh your version using git pull !" - check_if_continue + set +e + X=3 + git fetch + latest_commit_date=$(git log -1 --format=%cd --date=short) + remote_commit_date=$(git log -1 --format=%cd --date=short origin/master) + + if [[ "$OSTYPE" == "darwin"* ]] + then + latest_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$latest_commit_date" +%s) + remote_commit_date_seconds=$(date -j -f "%Y-%m-%d" "$remote_commit_date" +%s) + else + latest_commit_date_seconds=$(date -d "$latest_commit_date" +%s) + remote_commit_date_seconds=$(date -d "$remote_commit_date" +%s) + fi + + difference=$(( (remote_commit_date_seconds - latest_commit_date_seconds) / (60*60*24) )) + + if [ $difference -gt $X ] + then + logwarn "šŸ„¶ The current repo version is older than $X days ($difference days), please refresh your version using git pull ! (disable with 'playground config check-repo-version false')" + check_if_continue + fi + set -e fi - set -e } function set_profiles() {