Documentation
¶
Index ¶
- func NewCmdConsumeMessage(config *configuration.Configuration) *cobra.Command
- func NewCmdConsumer(config *configuration.Configuration) *cobra.Command
- func NewCmdDeleteConsumer(config *configuration.Configuration) *cobra.Command
- func NewCmdDescribeConsumer(config *configuration.Configuration) *cobra.Command
- func NewCmdLagConsumer(config *configuration.Configuration) *cobra.Command
- func NewCmdListConsumer(config *configuration.Configuration) *cobra.Command
- func NewCmdResetOffset(config *configuration.Configuration) *cobra.Command
- func ValidConsumers(config *configuration.Configuration, hasArgs bool) ([]string, cobra.ShellCompDirective)
- func ValidTopics(config *configuration.Configuration, hasArgs bool) ([]string, cobra.ShellCompDirective)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCmdConsumeMessage ¶
func NewCmdConsumeMessage(config *configuration.Configuration) *cobra.Command
func NewCmdConsumer ¶
func NewCmdConsumer(config *configuration.Configuration) *cobra.Command
func NewCmdDeleteConsumer ¶
func NewCmdDeleteConsumer(config *configuration.Configuration) *cobra.Command
func NewCmdDescribeConsumer ¶
func NewCmdDescribeConsumer(config *configuration.Configuration) *cobra.Command
func NewCmdLagConsumer ¶
func NewCmdLagConsumer(config *configuration.Configuration) *cobra.Command
func NewCmdListConsumer ¶
func NewCmdListConsumer(config *configuration.Configuration) *cobra.Command
func NewCmdResetOffset ¶ added in v0.1.9
func NewCmdResetOffset(config *configuration.Configuration) *cobra.Command
func ValidConsumers ¶
func ValidConsumers( config *configuration.Configuration, hasArgs bool, ) ([]string, cobra.ShellCompDirective)
func ValidTopics ¶
func ValidTopics( config *configuration.Configuration, hasArgs bool, ) ([]string, cobra.ShellCompDirective)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.