topic

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 29, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

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 CheckTopicNameTwoArgs(args []string) error

func Command

func Command(flagGrouping *cmdutils.FlagGrouping) *cobra.Command

func CompactCmd

func CompactCmd(vc *cmdutils.VerbCmd)

func CreateTopicCmd

func CreateTopicCmd(vc *cmdutils.VerbCmd)

func DeleteTopicCmd

func DeleteTopicCmd(vc *cmdutils.VerbCmd)

func GetBundleRangeCmd

func GetBundleRangeCmd(vc *cmdutils.VerbCmd)

func GetInternalInfoCmd

func GetInternalInfoCmd(vc *cmdutils.VerbCmd)

func GetInternalStatsCmd

func GetInternalStatsCmd(vc *cmdutils.VerbCmd)

func GetLastMessageIDCmd

func GetLastMessageIDCmd(vc *cmdutils.VerbCmd)

func GetPermissionsCmd

func GetPermissionsCmd(vc *cmdutils.VerbCmd)

func GetStatsCmd

func GetStatsCmd(vc *cmdutils.VerbCmd)

func GetTopicCmd

func GetTopicCmd(vc *cmdutils.VerbCmd)

func GrantPermissionCmd

func GrantPermissionCmd(vc *cmdutils.VerbCmd)

func ListTopicsCmd

func ListTopicsCmd(vc *cmdutils.VerbCmd)

func LookUpTopicCmd

func LookUpTopicCmd(vc *cmdutils.VerbCmd)

func OffloadCmd

func OffloadCmd(vc *cmdutils.VerbCmd)

func OffloadStatusCmd

func OffloadStatusCmd(vc *cmdutils.VerbCmd)

func RevokePermissions

func RevokePermissions(vc *cmdutils.VerbCmd)

func StatusCmd

func StatusCmd(vc *cmdutils.VerbCmd)

func TerminateCmd

func TerminateCmd(vc *cmdutils.VerbCmd)

func TestTopicCommands

func TestTopicCommands(newVerb func(cmd *cmdutils.VerbCmd), args []string) (out *bytes.Buffer,
	execErr, nameErr, err error)

func UnloadCmd

func UnloadCmd(vc *cmdutils.VerbCmd)

func UpdateTopicCmd

func UpdateTopicCmd(vc *cmdutils.VerbCmd)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL