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 GetBundleRangeCmd(vc *cmdutils.VerbCmd)
- func GetInternalInfoCmd(vc *cmdutils.VerbCmd)
- func GetInternalStatsCmd(vc *cmdutils.VerbCmd)
- func GetLastMessageIDCmd(vc *cmdutils.VerbCmd)
- func GetPermissionsCmd(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 RevokePermissions(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 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 GetBundleRangeCmd ¶
func GetInternalInfoCmd ¶
func GetInternalStatsCmd ¶
func GetLastMessageIDCmd ¶
func GetPermissionsCmd ¶
func GetStatsCmd ¶
func GetTopicCmd ¶
func GrantPermissionCmd ¶
func ListTopicsCmd ¶
func LookUpTopicCmd ¶
func OffloadCmd ¶
func OffloadStatusCmd ¶
func RevokePermissions ¶
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_permissions.go
- grant_permissions.go
- internal.go
- last_messageId.go
- list.go
- lookup_topic.go
- offload.go
- offload_status.go
- revoke_permissions.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.