Documentation
¶
Index ¶
- Variables
- func CheckTopicNameTwoArgs(args []string) error
- func Command(flagGrouping *cmdutils.FlagGrouping) *cobra.Command
- func CompactCmd(vc *cmdutils.VerbCmd)
- func CreateTopicCmd(vc *cmdutils.VerbCmd)
- func DeleteTopicCmd(vc *cmdutils.VerbCmd)
- func GetBacklogQuotaCmd(vc *cmdutils.VerbCmd)
- func GetBundleRangeCmd(vc *cmdutils.VerbCmd)
- func GetCompactionThresholdCmd(vc *cmdutils.VerbCmd)
- func GetDeduplicationStatusCmd(vc *cmdutils.VerbCmd)
- func GetDelayedDeliveryCmd(vc *cmdutils.VerbCmd)
- func GetDispatchRateCmd(vc *cmdutils.VerbCmd)
- func GetInactiveTopicCmd(vc *cmdutils.VerbCmd)
- func GetInternalInfoCmd(vc *cmdutils.VerbCmd)
- func GetInternalStatsCmd(vc *cmdutils.VerbCmd)
- func GetLastMessageIDCmd(vc *cmdutils.VerbCmd)
- func GetMaxConsumersCmd(vc *cmdutils.VerbCmd)
- func GetMaxProducersCmd(vc *cmdutils.VerbCmd)
- func GetMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)
- func GetMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)
- func GetMessageTTLCmd(vc *cmdutils.VerbCmd)
- func GetPermissionsCmd(vc *cmdutils.VerbCmd)
- func GetPersistenceCmd(vc *cmdutils.VerbCmd)
- func GetPublishRateCmd(vc *cmdutils.VerbCmd)
- func GetRetentionCmd(vc *cmdutils.VerbCmd)
- func GetStatsCmd(vc *cmdutils.VerbCmd)
- func GetTopicCmd(vc *cmdutils.VerbCmd)
- func GrantPermissionCmd(vc *cmdutils.VerbCmd)
- func ListTopicsCmd(vc *cmdutils.VerbCmd)
- func LookUpTopicCmd(vc *cmdutils.VerbCmd)
- func OffloadCmd(vc *cmdutils.VerbCmd)
- func OffloadStatusCmd(vc *cmdutils.VerbCmd)
- func RemoveBacklogQuotaCmd(vc *cmdutils.VerbCmd)
- func RemoveCompactionThresholdCmd(vc *cmdutils.VerbCmd)
- func RemoveDeduplicationStatusCmd(vc *cmdutils.VerbCmd)
- func RemoveDelayedDeliveryCmd(vc *cmdutils.VerbCmd)
- func RemoveDispatchRateCmd(vc *cmdutils.VerbCmd)
- func RemoveInactiveTopicCmd(vc *cmdutils.VerbCmd)
- func RemoveMaxConsumersCmd(vc *cmdutils.VerbCmd)
- func RemoveMaxProducersCmd(vc *cmdutils.VerbCmd)
- func RemoveMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)
- func RemoveMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)
- func RemoveMessageTTLCmd(vc *cmdutils.VerbCmd)
- func RemovePersistenceCmd(vc *cmdutils.VerbCmd)
- func RemovePublishRateCmd(vc *cmdutils.VerbCmd)
- func RemoveRetentionCmd(vc *cmdutils.VerbCmd)
- func RevokePermissions(vc *cmdutils.VerbCmd)
- func SetBacklogQuotaCmd(vc *cmdutils.VerbCmd)
- func SetCompactionThresholdCmd(vc *cmdutils.VerbCmd)
- func SetDeduplicationStatusCmd(vc *cmdutils.VerbCmd)
- func SetDelayedDeliveryCmd(vc *cmdutils.VerbCmd)
- func SetDispatchRateCmd(vc *cmdutils.VerbCmd)
- func SetInactiveTopicCmd(vc *cmdutils.VerbCmd)
- func SetMaxConsumersCmd(vc *cmdutils.VerbCmd)
- func SetMaxProducersCmd(vc *cmdutils.VerbCmd)
- func SetMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)
- func SetMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)
- func SetMessageTTLCmd(vc *cmdutils.VerbCmd)
- func SetPersistenceCmd(vc *cmdutils.VerbCmd)
- func SetPublishRateCmd(vc *cmdutils.VerbCmd)
- func SetRetentionCmd(vc *cmdutils.VerbCmd)
- func StatusCmd(vc *cmdutils.VerbCmd)
- func TerminateCmd(vc *cmdutils.VerbCmd)
- func TestTopicCommands(newVerb func(cmd *cmdutils.VerbCmd), args []string) (out *bytes.Buffer, execErr, nameErr, err error)
- func UnloadCmd(vc *cmdutils.VerbCmd)
- func UpdateTopicCmd(vc *cmdutils.VerbCmd)
Constants ¶
This section is empty.
Variables ¶
View Source
var ArgError = cmdutils.Output{
Desc: "the topic name is not specified or the topic name is specified more than one",
Out: "[✖] the topic name is not specified or the topic name is specified more than one",
}
View Source
var ArgsError = cmdutils.Output{
Desc: "the topic name and(or) the partitions is not specified",
Out: "[✖] need to specified the topic name and the partitions",
}
View Source
var InvalidPartitionsNumberError = cmdutils.Output{
Desc: "the partitions number is invalid",
Out: "[✖] invalid partition number '<number>'",
}
View Source
var NamespaceErrors = []cmdutils.Output{
{
Desc: "the namespace name is not in the format of <tenant>/<namespace>",
Out: "[✖] The complete name of namespace is invalid. complete name : <namespace-complete-name>",
},
{
Desc: "the tenant name and(or) namespace name is empty",
Out: "[✖] Invalid tenant or namespace. [<tenant>/<namespace>]",
},
{
Desc: "the tenant name contains unsupported special chars. " +
"the alphanumeric (a-zA-Z0-9) and the special chars (-=:.%) is allowed",
Out: "[✖] Tenant name include unsupported special chars. tenant : [<namespace>]",
},
{
Desc: "the namespace name contains unsupported special chars. " +
"the alphanumeric (a-zA-Z0-9) and the special chars (-=:.%) is allowed",
Out: "[✖] Namespace name include unsupported special chars. namespace : [<namespace>]",
},
}
View Source
var NamespaceNotExistError = cmdutils.Output{
Desc: "the namespace does not exist",
Out: "[✖] code: 404 reason: Namespace does not exist",
}
View Source
var TenantNotExistError = cmdutils.Output{
Desc: "the tenant of the namespace does not exist",
Out: "[✖] code: 404 reason: Tenant does not exist",
}
View Source
var TopicAlreadyExistError = cmdutils.Output{
Desc: "the topic has been created",
Out: "[✖] code: 409 reason: Partitioned topic already exists",
}
View Source
var TopicLevelPolicyNotEnabledError = cmdutils.Output{
Desc: "topic-level policy is not enabled",
Out: "[✖] code: 405 reason: Topic level policy is disabled, " +
"please enable broker configs of systemTopicEnabled and topicLevelPoliciesEnabled",
}
View Source
var TopicNameErrors = []cmdutils.Output{
{
Desc: "the topic name is not in the format of <tenant>/<namespace>/<topic> or <topic>",
Out: "[✖] Invalid short topic name '<topic-name>', it should be " +
"in the format of <tenant>/<namespace>/<topic> or <topic>",
},
{
Desc: "the topic name is not in the format of <domain>://<tenant>/<namespace>/<topic>",
Out: "[✖] Invalid complete topic name '<topic-name>', it should be in " +
"the format of <domain>://<tenant>/<namespace>/<topic>",
},
{
Desc: "the topic name is not in the format of <tenant>/<namespace>/<topic>",
Out: "[✖] Invalid topic name '<topic-name>', it should be in the format of" +
"<tenant>/<namespace>/<topic>",
},
}
View Source
var TopicNotFoundError = cmdutils.Output{
Desc: "the specified topic does not exist",
Out: "[✖] code: 404 reason: Topic not found",
}
Functions ¶
func CheckTopicNameTwoArgs ¶
func CompactCmd ¶
func CreateTopicCmd ¶
func DeleteTopicCmd ¶
func GetBacklogQuotaCmd ¶ added in v0.6.0
func GetBundleRangeCmd ¶
func GetCompactionThresholdCmd ¶ added in v0.6.0
func GetDeduplicationStatusCmd ¶ added in v0.6.0
func GetDelayedDeliveryCmd ¶ added in v0.6.0
func GetDispatchRateCmd ¶ added in v0.6.0
func GetInactiveTopicCmd ¶ added in v0.6.0
func GetInternalInfoCmd ¶
func GetInternalStatsCmd ¶
func GetLastMessageIDCmd ¶
func GetMaxConsumersCmd ¶ added in v0.6.0
func GetMaxProducersCmd ¶ added in v0.6.0
func GetMaxUnackMessagesPerConsumerCmd ¶ added in v0.6.0
func GetMaxUnackMessagesPerSubscriptionCmd ¶ added in v0.6.0
func GetMessageTTLCmd ¶ added in v0.6.0
func GetPermissionsCmd ¶
func GetPersistenceCmd ¶ added in v0.6.0
func GetPublishRateCmd ¶ added in v0.6.0
func GetRetentionCmd ¶ added in v0.6.0
func GetStatsCmd ¶
func GetTopicCmd ¶
func GrantPermissionCmd ¶
func ListTopicsCmd ¶
func LookUpTopicCmd ¶
func OffloadCmd ¶
func OffloadStatusCmd ¶
func RemoveBacklogQuotaCmd ¶ added in v0.6.0
func RemoveCompactionThresholdCmd ¶ added in v0.6.0
func RemoveDeduplicationStatusCmd ¶ added in v0.6.0
func RemoveDelayedDeliveryCmd ¶ added in v0.6.0
func RemoveDispatchRateCmd ¶ added in v0.6.0
func RemoveInactiveTopicCmd ¶ added in v0.6.0
func RemoveMaxConsumersCmd ¶ added in v0.6.0
func RemoveMaxProducersCmd ¶ added in v0.6.0
func RemoveMaxUnackMessagesPerConsumerCmd ¶ added in v0.6.0
func RemoveMaxUnackMessagesPerSubscriptionCmd ¶ added in v0.6.0
func RemoveMessageTTLCmd ¶ added in v0.6.0
func RemovePersistenceCmd ¶ added in v0.6.0
func RemovePublishRateCmd ¶ added in v0.6.0
func RemoveRetentionCmd ¶ added in v0.6.0
func RevokePermissions ¶
func SetBacklogQuotaCmd ¶ added in v0.6.0
func SetCompactionThresholdCmd ¶ added in v0.6.0
func SetDeduplicationStatusCmd ¶ added in v0.6.0
func SetDelayedDeliveryCmd ¶ added in v0.6.0
func SetDispatchRateCmd ¶ added in v0.6.0
func SetInactiveTopicCmd ¶ added in v0.6.0
func SetMaxConsumersCmd ¶ added in v0.6.0
func SetMaxProducersCmd ¶ added in v0.6.0
func SetMaxUnackMessagesPerConsumerCmd ¶ added in v0.6.0
func SetMaxUnackMessagesPerSubscriptionCmd ¶ added in v0.6.0
func SetMessageTTLCmd ¶ added in v0.6.0
func SetPersistenceCmd ¶ added in v0.6.0
func SetPublishRateCmd ¶ added in v0.6.0
func SetRetentionCmd ¶ added in v0.6.0
func TerminateCmd ¶
func TestTopicCommands ¶
func UpdateTopicCmd ¶
Types ¶
This section is empty.
Source Files
¶
- args_check.go
- bundle_range.go
- compact.go
- compact_status.go
- create.go
- delete.go
- errors_topic.go
- get.go
- get_backlog_quota.go
- get_compaction_threshold.go
- get_deduplication_status.go
- get_delayed_delivery.go
- get_dispatch_rate.go
- get_inactive_topic.go
- get_max_consumers.go
- get_max_producers.go
- get_max_unack_messages_per_consumer.go
- get_max_unack_messages_per_subscription.go
- get_message_ttl.go
- get_permissions.go
- get_persistence.go
- get_publish_rate.go
- get_retention.go
- grant_permissions.go
- internal.go
- last_messageId.go
- list.go
- lookup_topic.go
- offload.go
- offload_status.go
- remove_backlog_quota.go
- remove_compaction_threshold.go
- remove_deduplication_status.go
- remove_delayed_delivery.go
- remove_dispatch_rate.go
- remove_inactive_topic.go
- remove_max_consumer.go
- remove_max_producers.go
- remove_max_unack_messages_per_consumer.go
- remove_max_unack_messages_per_subscription.go
- remove_message_ttl.go
- remove_persistence.go
- remove_publish_rate.go
- remove_retention.go
- revoke_permissions.go
- set_backlog_quota.go
- set_compaction_threshold.go
- set_deduplication_status.go
- set_delayed_delivery.go
- set_dispatch_rate.go
- set_inactive_topic.go
- set_max_consumers.go
- set_max_producers.go
- set_max_unack_messages_per_consumer.go
- set_max_unack_messages_per_subscription.go
- set_message_ttl.go
- set_persistence.go
- set_publish_rate.go
- set_retention.go
- stats.go
- stats_internal.go
- teminate.go
- test_help.go
- topic.go
- unload.go
- update.go
Click to show internal directories.
Click to hide internal directories.