kafka

Oct 17, 2017

Changes in this version

+ type CommandOutput struct

+ Stderr string

+ Stdout string

+ type ConsumerGroupsCommandClient struct

+ BootstrapServers string

+ ConsumerGroupCommandPath string

+ Parser DescribeGroupParser

+ func (col *ConsumerGroupsCommandClient) DescribeGroup(ctx context.Context, group string) ([]exporter.PartitionInfo, error)

+ func (col *ConsumerGroupsCommandClient) Groups(ctx context.Context) ([]string, error)

+ type DelegatingParser struct

+ Parsers []DescribeGroupParser

+ func DefaultDescribeGroupParser() *DelegatingParser

+ func (p *DelegatingParser) Parse(output CommandOutput) ([]exporter.PartitionInfo, error)

+ func (p *DelegatingParser) String() string

+ type DescribeGroupParser interface

+ Parse func(output CommandOutput) ([]exporter.PartitionInfo, error)