in cmd/cli/queue.go [25:82]
func buildQueueCmd() *cobra.Command {
queueCmd := &cobra.Command{
Use: "queue",
Short: "Queue Operations",
}
queueCreateCmd := &cobra.Command{
Use: "create",
Short: "creates queue",
Run: func(cmd *cobra.Command, args []string) {
checkError(cmd, queue.CreateQueue())
},
}
queue.InitCreateFlags(queueCreateCmd)
queueCmd.AddCommand(queueCreateCmd)
queueDeleteCmd := &cobra.Command{
Use: "delete",
Short: "delete queue",
Run: func(cmd *cobra.Command, args []string) {
checkError(cmd, queue.DeleteQueue())
},
}
queue.InitDeleteFlags(queueDeleteCmd)
queueCmd.AddCommand(queueDeleteCmd)
queueOperateCmd := &cobra.Command{
Use: "operate queue",
Short: "operate queue",
Run: func(cmd *cobra.Command, args []string) {
checkError(cmd, queue.OperateQueue())
},
}
queue.InitOperateFlags(queueOperateCmd)
queueCmd.AddCommand(queueOperateCmd)
queueListCmd := &cobra.Command{
Use: "list",
Short: "lists all the queue",
Run: func(cmd *cobra.Command, args []string) {
checkError(cmd, queue.ListQueue())
},
}
queue.InitListFlags(queueListCmd)
queueCmd.AddCommand(queueListCmd)
queueGetCmd := &cobra.Command{
Use: "get",
Short: "get a queue",
Run: func(cmd *cobra.Command, args []string) {
checkError(cmd, queue.GetQueue())
},
}
queue.InitGetFlags(queueGetCmd)
queueCmd.AddCommand(queueGetCmd)
return queueCmd
}