Skip to content

Commit 2bf44f4

Browse files
authored
Merge pull request #637 from M00nF1sh/yyyng-dev
1. Fix issues with targetgroup
2 parents c964442 + f1f19bd commit 2bf44f4

File tree

2 files changed

+12
-6
lines changed

2 files changed

+12
-6
lines changed

internal/alb/tg/targetgroups.go

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -108,19 +108,17 @@ type NewDesiredTargetGroupsOptions struct {
108108

109109
// NewDesiredTargetGroups returns a new targetgroups.TargetGroups based on an extensions.Ingress.
110110
func NewDesiredTargetGroups(o *NewDesiredTargetGroupsOptions) (TargetGroups, error) {
111-
var output TargetGroups
112111
var backends []*extensions.IngressBackend
113-
114112
if o.Ingress.Spec.Backend != nil {
115113
backends = append(backends, o.Ingress.Spec.Backend)
116114
}
117-
118115
for _, rule := range o.Ingress.Spec.Rules {
119116
for i := range rule.HTTP.Paths {
120117
backends = append(backends, &rule.HTTP.Paths[i].Backend)
121118
}
122119
}
123120

121+
var targetGroupsInUse TargetGroups
124122
for _, backend := range backends {
125123
if action.Use(backend.ServicePort.String()) {
126124
// action annotations do not need target groups
@@ -138,11 +136,17 @@ func NewDesiredTargetGroups(o *NewDesiredTargetGroupsOptions) (TargetGroups, err
138136
})
139137

140138
if err != nil {
141-
return nil, err
139+
return o.ExistingTargetGroups, err
142140
}
143-
144-
output = append(output, targetGroup)
141+
targetGroupsInUse = append(targetGroupsInUse, targetGroup)
145142
}
146143

144+
output := targetGroupsInUse
145+
for _, tg := range o.ExistingTargetGroups {
146+
if _, tgInUse := targetGroupsInUse.FindById(tg.ID); tgInUse == nil {
147+
tg.StripDesiredState()
148+
output = append(output, tg)
149+
}
150+
}
147151
return output, nil
148152
}

internal/albingress/albingresses.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,8 @@ func (a ALBIngresses) RemovedIngresses(newList ALBIngresses) ALBIngresses {
133133
// no longer relevant to the ALBController.
134134
if ingress.loadBalancer != nil {
135135
ingress.stripDesiredState()
136+
ingress.resetBackoff()
137+
ingress.valid = true
136138
deleteableIngress = append(deleteableIngress, ingress)
137139
}
138140
}

0 commit comments

Comments
 (0)