Skip to content

Commit

Permalink
Update command descriptions from old 'property/cluster/namespace' for…
Browse files Browse the repository at this point in the history
…mat to current 'tenant/namespace' format (apache#10485)

* Update command descriptions from old 'property/cluster/namespace' format to current 'tenant/namespace' format

* fix typo

* fix namespaces word

Co-authored-by: Chris Bartholomew <[email protected]>
  • Loading branch information
eolivelli and cdbartholomew authored Nov 12, 2021
1 parent dee8887 commit c1ecb68
Show file tree
Hide file tree
Showing 3 changed files with 40 additions and 40 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ private NonPersistentTopics getNonPersistentTopics() {

@Parameters(commandDescription = "Lookup a topic from the current serving broker")
private class Lookup extends CliCommand {
@Parameter(description = "non-persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "non-persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -66,7 +66,7 @@ void run() throws PulsarAdminException {
@Parameters(commandDescription = "Get the stats for the topic and its connected producers and consumers. "
+ "All the rates are computed over a 1 minute window and are relative the last completed 1 minute period.")
private class GetStats extends CliCommand {
@Parameter(description = "non-persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "non-persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -78,7 +78,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get the internal stats for the topic")
private class GetInternalStats extends CliCommand {
@Parameter(description = "non-persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "non-persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -92,7 +92,7 @@ void run() throws PulsarAdminException {
+ "The partitioned topic has to be created before creating a producer on it.")
private class CreatePartitionedCmd extends CliCommand {

@Parameter(description = "non-persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "non-persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-p",
Expand All @@ -110,7 +110,7 @@ void run() throws Exception {
+ "If the topic is not created or is a non-partitioned topic, it returns empty topic with 0 partitions")
private class GetPartitionedTopicMetadataCmd extends CliCommand {

@Parameter(description = "non-persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "non-persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -122,7 +122,7 @@ void run() throws Exception {

@Parameters(commandDescription = "Get list of non-persistent topics present under a namespace")
private class GetList extends CliCommand {
@Parameter(description = "property/cluster/namespace", required = true)
@Parameter(description = "tenant/namespace", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -134,7 +134,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get list of non-persistent topics present under a namespace bundle")
private class GetListInBundle extends CliCommand {
@Parameter(description = "property/cluster/namespace", required = true)
@Parameter(description = "tenant/namespace", required = true)
private java.util.List<String> params;

@Parameter(names = { "-b",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ private Topics getPersistentTopics() {

@Parameters(commandDescription = "Get the list of topics under a namespace.")
private class ListCmd extends CliCommand {
@Parameter(description = "property/cluster/namespace", required = true)
@Parameter(description = "tenant/namespace", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -105,7 +105,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get the list of partitioned topics under a namespace.")
private class PartitionedTopicListCmd extends CliCommand {
@Parameter(description = "property/cluster/namespace", required = true)
@Parameter(description = "tenant/namespace", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -117,7 +117,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Grant a new permission to a client role on a single topic.")
private class GrantPermissions extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = "--role", description = "Client role to which grant permissions", required = true)
Expand All @@ -139,7 +139,7 @@ void run() throws PulsarAdminException {
+ "was not set at the topic level, but rather at the namespace level, this "
+ "operation will return an error (HTTP status code 412).")
private class RevokePermissions extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = "--role", description = "Client role to which revoke permissions", required = true)
Expand All @@ -157,7 +157,7 @@ void run() throws PulsarAdminException {
+ "by the permissions set at the namespace level combined (union) with any eventual "
+ "specific permission set on the topic.")
private class Permissions extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -169,7 +169,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Lookup a topic from the current serving broker")
private class Lookup extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -181,7 +181,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get Namespace bundle range of a topic")
private class GetBundleRange extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -195,7 +195,7 @@ void run() throws PulsarAdminException {
+ "The partitioned topic has to be created before creating a producer on it.")
private class CreatePartitionedCmd extends CliCommand {

@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-p",
Expand All @@ -213,7 +213,7 @@ void run() throws Exception {
+ "New updating number of partitions must be greater than existing number of partitions.")
private class UpdatePartitionedCmd extends CliCommand {

@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-p",
Expand All @@ -231,7 +231,7 @@ void run() throws Exception {
+ "If the topic is not created or is a non-partitioned topic, it returns empty topic with 0 partitions")
private class GetPartitionedTopicMetadataCmd extends CliCommand {

@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -245,7 +245,7 @@ void run() throws Exception {
+ "It will also delete all the partitions of the topic if it exists.")
private class DeletePartitionedCmd extends CliCommand {

@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = "--force", description = "Close all producer/consumer/replicator and delete topic forcefully")
Expand All @@ -261,7 +261,7 @@ void run() throws Exception {
@Parameters(commandDescription = "Delete a topic. "
+ "The topic cannot be deleted if there's any active subscription or producers connected to it.")
private class DeleteCmd extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = "--force", description = "Close all producer/consumer/replicator and delete topic forcefully")
Expand All @@ -276,7 +276,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Unload a topic.")
private class UnloadCmd extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -301,7 +301,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get the list of subscriptions on the topic")
private class ListSubscriptions extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -314,7 +314,7 @@ void run() throws Exception {
@Parameters(commandDescription = "Delete a durable subscriber from a topic. "
+ "The subscription cannot be deleted if there are any active consumers attached to it")
private class DeleteSubscription extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-f",
Expand All @@ -334,7 +334,7 @@ void run() throws PulsarAdminException {
@Parameters(commandDescription = "Get the stats for the topic and its connected producers and consumers. "
+ "All the rates are computed over a 1 minute window and are relative the last completed 1 minute period.")
private class GetStats extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-gpb", "--get-precise-backlog" }, description = "Set true to get precise backlog")
Expand All @@ -349,7 +349,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get the internal stats for the topic")
private class GetInternalStats extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-m",
Expand All @@ -365,7 +365,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Get the internal metadata info for the topic")
private class GetInternalInfo extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -380,7 +380,7 @@ void run() throws PulsarAdminException {
@Parameters(commandDescription = "Get the stats for the partitioned topic and its connected producers and consumers. "
+ "All the rates are computed over a 1 minute window and are relative the last completed 1 minute period.")
private class GetPartitionedStats extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = "--per-partition", description = "Get per partition stats")
Expand All @@ -396,7 +396,7 @@ void run() throws Exception {
@Parameters(commandDescription = "Get the stats-internal for the partitioned topic and its connected producers and consumers. "
+ "All the rates are computed over a 1 minute window and are relative the last completed 1 minute period.")
private class GetPartitionedStatsInternal extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -408,7 +408,7 @@ void run() throws Exception {

@Parameters(commandDescription = "Skip all the messages for the subscription")
private class SkipAll extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s", "--subscription" }, description = "Subscription to be cleared", required = true)
Expand All @@ -423,7 +423,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Skip some messages for the subscription")
private class Skip extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s",
Expand All @@ -442,7 +442,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Expire messages that older than given expiry time (in seconds) for the subscription")
private class ExpireMessages extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s",
Expand All @@ -461,7 +461,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Expire messages that older than given expiry time (in seconds) for all subscriptions")
private class ExpireMessagesForAllSubscriptions extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-t", "--expireTime" }, description = "Expire messages older than time in seconds", required = true)
Expand All @@ -476,7 +476,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Create a new subscription on a topic")
private class CreateSubscription extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s",
Expand Down Expand Up @@ -505,7 +505,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Reset position for subscription to position closest to timestamp or messageId")
private class ResetCursor extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s",
Expand Down Expand Up @@ -541,7 +541,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Terminate a topic and don't allow any more messages to be published")
private class Terminate extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -559,7 +559,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Peek some messages for the subscription")
private class PeekMessages extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-s",
Expand Down Expand Up @@ -637,7 +637,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Compact a topic")
private class Compact extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Override
Expand All @@ -651,7 +651,7 @@ void run() throws PulsarAdminException {

@Parameters(commandDescription = "Status of compaction on a topic")
private class CompactionStatusCmd extends CliCommand {
@Parameter(description = "persistent://property/cluster/namespace/topic", required = true)
@Parameter(description = "persistent://tenant/namespace/topic", required = true)
private java.util.List<String> params;

@Parameter(names = { "-w", "--wait-complete" },
Expand Down
Loading

0 comments on commit c1ecb68

Please sign in to comment.