|
@@ -802,7 +802,7 @@ func (ca *clusterAdmin) ListConsumerGroups() (allGroups map[string]string, err e
|
|
|
|
|
|
brokers := ca.client.Brokers()
|
|
brokers := ca.client.Brokers()
|
|
groupMaps := make(chan map[string]string, len(brokers))
|
|
groupMaps := make(chan map[string]string, len(brokers))
|
|
- errors := make(chan error, len(brokers))
|
|
+ errChan := make(chan error, len(brokers))
|
|
wg := sync.WaitGroup{}
|
|
wg := sync.WaitGroup{}
|
|
|
|
|
|
for _, b := range brokers {
|
|
for _, b := range brokers {
|
|
@@ -813,7 +813,7 @@ func (ca *clusterAdmin) ListConsumerGroups() (allGroups map[string]string, err e
|
|
|
|
|
|
response, err := b.ListGroups(&ListGroupsRequest{})
|
|
response, err := b.ListGroups(&ListGroupsRequest{})
|
|
if err != nil {
|
|
if err != nil {
|
|
- errors <- err
|
|
+ errChan <- err
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
@@ -828,7 +828,7 @@ func (ca *clusterAdmin) ListConsumerGroups() (allGroups map[string]string, err e
|
|
|
|
|
|
wg.Wait()
|
|
wg.Wait()
|
|
close(groupMaps)
|
|
close(groupMaps)
|
|
- close(errors)
|
|
+ close(errChan)
|
|
|
|
|
|
for groupMap := range groupMaps {
|
|
for groupMap := range groupMaps {
|
|
for group, protocolType := range groupMap {
|
|
for group, protocolType := range groupMap {
|
|
@@ -837,7 +837,7 @@ func (ca *clusterAdmin) ListConsumerGroups() (allGroups map[string]string, err e
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- err = <-errors
|
|
+ err = <-errChan
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
@@ -893,7 +893,7 @@ func (ca *clusterAdmin) DescribeLogDirs(brokerIds []int32) (allLogDirs map[int32
|
|
|
|
|
|
|
|
|
|
logDirsMaps := make(chan map[int32][]DescribeLogDirsResponseDirMetadata, len(brokerIds))
|
|
logDirsMaps := make(chan map[int32][]DescribeLogDirsResponseDirMetadata, len(brokerIds))
|
|
- errors := make(chan error, len(brokerIds))
|
|
+ errChan := make(chan error, len(brokerIds))
|
|
wg := sync.WaitGroup{}
|
|
wg := sync.WaitGroup{}
|
|
|
|
|
|
for _, b := range brokerIds {
|
|
for _, b := range brokerIds {
|
|
@@ -909,7 +909,7 @@ func (ca *clusterAdmin) DescribeLogDirs(brokerIds []int32) (allLogDirs map[int32
|
|
|
|
|
|
response, err := b.DescribeLogDirs(&DescribeLogDirsRequest{})
|
|
response, err := b.DescribeLogDirs(&DescribeLogDirsRequest{})
|
|
if err != nil {
|
|
if err != nil {
|
|
- errors <- err
|
|
+ errChan <- err
|
|
return
|
|
return
|
|
}
|
|
}
|
|
logDirs := make(map[int32][]DescribeLogDirsResponseDirMetadata)
|
|
logDirs := make(map[int32][]DescribeLogDirsResponseDirMetadata)
|
|
@@ -920,7 +920,7 @@ func (ca *clusterAdmin) DescribeLogDirs(brokerIds []int32) (allLogDirs map[int32
|
|
|
|
|
|
wg.Wait()
|
|
wg.Wait()
|
|
close(logDirsMaps)
|
|
close(logDirsMaps)
|
|
- close(errors)
|
|
+ close(errChan)
|
|
|
|
|
|
for logDirsMap := range logDirsMaps {
|
|
for logDirsMap := range logDirsMaps {
|
|
for id, logDirs := range logDirsMap {
|
|
for id, logDirs := range logDirsMap {
|
|
@@ -929,6 +929,6 @@ func (ca *clusterAdmin) DescribeLogDirs(brokerIds []int32) (allLogDirs map[int32
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- err = <-errors
|
|
+ err = <-errChan
|
|
return
|
|
return
|
|
}
|
|
}
|