File tree Expand file tree Collapse file tree 2 files changed +16
-10
lines changed
Expand file tree Collapse file tree 2 files changed +16
-10
lines changed Original file line number Diff line number Diff line change @@ -497,10 +497,11 @@ func main() {
497497 ClusterName : clusterName ,
498498 }
499499 cleaner .ENICleaner = & eniCleaner.ENICleaner {
500- EC2Wrapper : ec2Wrapper ,
501- Manager : cleaner ,
502- VpcId : vpcID ,
503- Log : ctrl .Log .WithName ("eniCleaner" ).WithName ("cluster" ),
500+ EC2Wrapper : ec2Wrapper ,
501+ Manager : cleaner ,
502+ VpcId : vpcID ,
503+ Log : ctrl .Log .WithName ("eniCleaner" ).WithName ("cluster" ),
504+ ControllerDisabled : disableController ,
504505 }
505506
506507 if err := cleaner .SetupWithManager (ctx , mgr , healthzHandler ); err != nil {
Original file line number Diff line number Diff line change @@ -44,10 +44,11 @@ type NetworkInterfaceManager interface {
4444}
4545
4646type ENICleaner struct {
47- EC2Wrapper api.EC2Wrapper
48- Manager NetworkInterfaceManager
49- VpcId string
50- Log logr.Logger
47+ EC2Wrapper api.EC2Wrapper
48+ Manager NetworkInterfaceManager
49+ VpcId string
50+ Log logr.Logger
51+ ControllerDisabled bool
5152}
5253
5354// common filters for describing network interfaces
@@ -122,8 +123,12 @@ func (e *ENICleaner) DeleteLeakedResources() error {
122123 Values : []string {e .VpcId },
123124 },
124125 }... )
125- // get cleaner specific filters
126- filters = append (filters , e .Manager .GetENITagFilters ()... )
126+
127+ // only apply extra filters when the controller is enabled which provides cninode resources
128+ if ! e .ControllerDisabled {
129+ // get cleaner specific filters
130+ filters = append (filters , e .Manager .GetENITagFilters ()... )
131+ }
127132 describeNetworkInterfaceIp := & ec2.DescribeNetworkInterfacesInput {
128133 Filters : filters ,
129134 }
You can’t perform that action at this time.
0 commit comments