kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Paginate DescribeNetworkInterfaces calls 

This should help with VPCs containing large numbers of ENIs

Signed-off-by: Peter Rifel <pgrifel@gmail.com>
This commit is contained in:
Peter Rifel 2023-09-06 21:34:27 -05:00
parent 0086ad9a85
commit 7ec30b4a98
No known key found for this signature in database
GPG Key ID: BC6469E5B16DB2B6
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/resources/aws/eni.go
View File

@ -72,18 +72,19 @@ func DescribeENIs(cloud fi.Cloud, clusterName string) (map[string]*ec2.NetworkIn
request := &ec2.DescribeNetworkInterfacesInput{ request := &ec2.DescribeNetworkInterfacesInput{
Filters: filters, Filters: filters,
} }
response, err := c.EC2().DescribeNetworkInterfaces(request) err := c.EC2().DescribeNetworkInterfacesPages(request, func(dnio *ec2.DescribeNetworkInterfacesOutput, b bool) bool {
if err != nil { for _, eni := range dnio.NetworkInterfaces {
return nil, fmt.Errorf("error listing ENIs: %v", err)
}
for _, eni := range response.NetworkInterfaces {
// Skip ENIs that are attached // Skip ENIs that are attached
if eni.Attachment != nil { if eni.Attachment != nil {
continue continue
} }
enis[aws.StringValue(eni.NetworkInterfaceId)] = eni enis[aws.StringValue(eni.NetworkInterfaceId)] = eni
} }
return true
})
if err != nil {
return nil, fmt.Errorf("error listing ENIs: %v", err)
}
} }
return enis, nil return enis, nil