topic

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Jul 1, 2025 License: Apache-2.0 Imports: 13 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 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 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 GetBacklogQuotaCmd added in v0.6.0

func GetBacklogQuotaCmd(vc *cmdutils.VerbCmd)

func GetBundleRangeCmd

func GetBundleRangeCmd(vc *cmdutils.VerbCmd)

func GetCompactionThresholdCmd added in v0.6.0

func GetCompactionThresholdCmd(vc *cmdutils.VerbCmd)

func GetDeduplicationStatusCmd added in v0.6.0

func GetDeduplicationStatusCmd(vc *cmdutils.VerbCmd)

func GetDelayedDeliveryCmd added in v0.6.0

func GetDelayedDeliveryCmd(vc *cmdutils.VerbCmd)

func GetDispatchRateCmd added in v0.6.0

func GetDispatchRateCmd(vc *cmdutils.VerbCmd)

func GetInactiveTopicCmd added in v0.6.0

func GetInactiveTopicCmd(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 GetMaxConsumersCmd added in v0.6.0

func GetMaxConsumersCmd(vc *cmdutils.VerbCmd)

func GetMaxProducersCmd added in v0.6.0

func GetMaxProducersCmd(vc *cmdutils.VerbCmd)

func GetMaxUnackMessagesPerConsumerCmd added in v0.6.0

func GetMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)

func GetMaxUnackMessagesPerSubscriptionCmd added in v0.6.0

func GetMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)

func GetMessageTTLCmd added in v0.6.0

func GetMessageTTLCmd(vc *cmdutils.VerbCmd)

func GetPermissionsCmd

func GetPermissionsCmd(vc *cmdutils.VerbCmd)

func GetPersistenceCmd added in v0.6.0

func GetPersistenceCmd(vc *cmdutils.VerbCmd)

func GetPublishRateCmd added in v0.6.0

func GetPublishRateCmd(vc *cmdutils.VerbCmd)

func GetRetentionCmd added in v0.6.0

func GetRetentionCmd(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 RemoveBacklogQuotaCmd added in v0.6.0

func RemoveBacklogQuotaCmd(vc *cmdutils.VerbCmd)

func RemoveCompactionThresholdCmd added in v0.6.0

func RemoveCompactionThresholdCmd(vc *cmdutils.VerbCmd)

func RemoveDeduplicationStatusCmd added in v0.6.0

func RemoveDeduplicationStatusCmd(vc *cmdutils.VerbCmd)

func RemoveDelayedDeliveryCmd added in v0.6.0

func RemoveDelayedDeliveryCmd(vc *cmdutils.VerbCmd)

func RemoveDispatchRateCmd added in v0.6.0

func RemoveDispatchRateCmd(vc *cmdutils.VerbCmd)

func RemoveInactiveTopicCmd added in v0.6.0

func RemoveInactiveTopicCmd(vc *cmdutils.VerbCmd)

func RemoveMaxConsumersCmd added in v0.6.0

func RemoveMaxConsumersCmd(vc *cmdutils.VerbCmd)

func RemoveMaxProducersCmd added in v0.6.0

func RemoveMaxProducersCmd(vc *cmdutils.VerbCmd)

func RemoveMaxUnackMessagesPerConsumerCmd added in v0.6.0

func RemoveMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)

func RemoveMaxUnackMessagesPerSubscriptionCmd added in v0.6.0

func RemoveMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)

func RemoveMessageTTLCmd added in v0.6.0

func RemoveMessageTTLCmd(vc *cmdutils.VerbCmd)

func RemovePersistenceCmd added in v0.6.0

func RemovePersistenceCmd(vc *cmdutils.VerbCmd)

func RemovePublishRateCmd added in v0.6.0

func RemovePublishRateCmd(vc *cmdutils.VerbCmd)

func RemoveRetentionCmd added in v0.6.0

func RemoveRetentionCmd(vc *cmdutils.VerbCmd)

func RevokePermissions

func RevokePermissions(vc *cmdutils.VerbCmd)

func SetBacklogQuotaCmd added in v0.6.0

func SetBacklogQuotaCmd(vc *cmdutils.VerbCmd)

func SetCompactionThresholdCmd added in v0.6.0

func SetCompactionThresholdCmd(vc *cmdutils.VerbCmd)

func SetDeduplicationStatusCmd added in v0.6.0

func SetDeduplicationStatusCmd(vc *cmdutils.VerbCmd)

func SetDelayedDeliveryCmd added in v0.6.0

func SetDelayedDeliveryCmd(vc *cmdutils.VerbCmd)

func SetDispatchRateCmd added in v0.6.0

func SetDispatchRateCmd(vc *cmdutils.VerbCmd)

func SetInactiveTopicCmd added in v0.6.0

func SetInactiveTopicCmd(vc *cmdutils.VerbCmd)

func SetMaxConsumersCmd added in v0.6.0

func SetMaxConsumersCmd(vc *cmdutils.VerbCmd)

func SetMaxProducersCmd added in v0.6.0

func SetMaxProducersCmd(vc *cmdutils.VerbCmd)

func SetMaxUnackMessagesPerConsumerCmd added in v0.6.0

func SetMaxUnackMessagesPerConsumerCmd(vc *cmdutils.VerbCmd)

func SetMaxUnackMessagesPerSubscriptionCmd added in v0.6.0

func SetMaxUnackMessagesPerSubscriptionCmd(vc *cmdutils.VerbCmd)

func SetMessageTTLCmd added in v0.6.0

func SetMessageTTLCmd(vc *cmdutils.VerbCmd)

func SetPersistenceCmd added in v0.6.0

func SetPersistenceCmd(vc *cmdutils.VerbCmd)

func SetPublishRateCmd added in v0.6.0

func SetPublishRateCmd(vc *cmdutils.VerbCmd)

func SetRetentionCmd added in v0.6.0

func SetRetentionCmd(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