consumergroups

Documentation

Index

• func CompleteConsumerGroups(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)
• func CompleteConsumerGroupsFiltered(flags DescribeConsumerGroupFlags) ([]string, cobra.ShellCompDirective)
• type ConsumerGroupOperation
  • func (operation *ConsumerGroupOperation) DeleteConsumerGroups(consumerGroups []string) error
  • func (operation *ConsumerGroupOperation) DescribeConsumerGroup(flags DescribeConsumerGroupFlags, group string) error
  • func (operation *ConsumerGroupOperation) GetConsumerGroups(flags GetConsumerGroupFlags) error
• type DescribeConsumerGroupFlags
• type GetConsumerGroupFlags

Functions

func CompleteConsumerGroups

func CompleteConsumerGroups(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)

func CompleteConsumerGroupsFiltered

func CompleteConsumerGroupsFiltered(flags DescribeConsumerGroupFlags) ([]string, cobra.ShellCompDirective)

Types

type ConsumerGroupOperation

type ConsumerGroupOperation struct {
}

func (*ConsumerGroupOperation) DeleteConsumerGroups

func (operation *ConsumerGroupOperation) DeleteConsumerGroups(consumerGroups []string) error

func (*ConsumerGroupOperation) DescribeConsumerGroup

func (operation *ConsumerGroupOperation) DescribeConsumerGroup(flags DescribeConsumerGroupFlags, group string) error

func (*ConsumerGroupOperation) GetConsumerGroups

func (operation *ConsumerGroupOperation) GetConsumerGroups(flags GetConsumerGroupFlags) error

type DescribeConsumerGroupFlags

type DescribeConsumerGroupFlags struct {
	OnlyPartitionsWithLag bool
	FilterTopic           string
	OutputFormat          string
	PrintTopics           bool
	PrintMembers          bool
}

type GetConsumerGroupFlags

type GetConsumerGroupFlags struct {
	OutputFormat string
	FilterTopic  string
}