subscription

Documentation

Index

• Variables
• func CheckSubscriptionNameTwoArgs(args []string) error
• func Command(flagGrouping *cmdutils.FlagGrouping) *cobra.Command
• func CreateCmd(vc *cmdutils.VerbCmd)
• func DeleteCmd(vc *cmdutils.VerbCmd)
• func ExpireCmd(vc *cmdutils.VerbCmd)
• func ListCmd(vc *cmdutils.VerbCmd)
• func PeekCmd(vc *cmdutils.VerbCmd)
• func ResetCursorCmd(vc *cmdutils.VerbCmd)
• func SkipCmd(vc *cmdutils.VerbCmd)
• func TestSubCommands(newVerb func(cmd *cmdutils.VerbCmd), args []string) (out *bytes.Buffer, execErr, nameErr, err error)

Variables

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",
}

var ArgsError = cmdutils.Output{
	Desc: "the topic name and(or) the subscription name is not specified",
	Out:  "[✖]  need to specified the topic name and the subscription name",
}

var MessageIDErrors = []cmdutils.Output{
	{
		Desc: "the split of message id is not valid",
		Out:  "[✖]  Invalid message id string. <message-id>",
	},
	{
		Desc: "the ledger id is not valid",
		Out:  "[✖]  Invalid ledger id string. <message-id>",
	},
	{
		Desc: "the entry id is not valid",
		Out:  "[✖]  Invalid entry id string. <message-id>",
	},
}

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>]",
	},
}

var SubNotFoundError = cmdutils.Output{
	Desc: "the specified subscription does not exist",
	Out:  "[✖]  code: 404 reason: Subscription not found",
}

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>",
	},
}

var TopicNotFoundError = cmdutils.Output{
	Desc: "the specified topic does not exist",
	Out:  "[✖]  code: 404 reason: Topic not found",
}

Functions

func CheckSubscriptionNameTwoArgs

func CheckSubscriptionNameTwoArgs(args []string) error

func Command

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

func CreateCmd

func CreateCmd(vc *cmdutils.VerbCmd)

func DeleteCmd

func DeleteCmd(vc *cmdutils.VerbCmd)

func ExpireCmd

func ExpireCmd(vc *cmdutils.VerbCmd)

func ListCmd

func ListCmd(vc *cmdutils.VerbCmd)

func PeekCmd

func PeekCmd(vc *cmdutils.VerbCmd)

func ResetCursorCmd

func ResetCursorCmd(vc *cmdutils.VerbCmd)

func SkipCmd

func SkipCmd(vc *cmdutils.VerbCmd)

func TestSubCommands

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