Skip to content

Commit 06a8235

Browse files
committed
fix securityGroup ipv4 detection
1 parent bf1a6be commit 06a8235

File tree

2 files changed

+8
-10
lines changed

2 files changed

+8
-10
lines changed

pkg/build/lb_security_group.go

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@ package build
33
import (
44
"context"
55
"fmt"
6+
"net"
7+
"strings"
8+
69
"github.com/aws/aws-sdk-go/aws"
710
"github.com/aws/aws-sdk-go/aws/arn"
811
"github.com/aws/aws-sdk-go/service/ec2"
@@ -14,12 +17,10 @@ import (
1417
"k8s.io/apimachinery/pkg/types"
1518
"k8s.io/apimachinery/pkg/util/intstr"
1619
"k8s.io/apimachinery/pkg/util/sets"
17-
"net"
1820
api "sigs.k8s.io/aws-alb-ingress-controller/pkg/apis/ingress/v1alpha1"
1921
"sigs.k8s.io/aws-alb-ingress-controller/pkg/cloud"
2022
"sigs.k8s.io/aws-alb-ingress-controller/pkg/ingress"
2123
"sigs.k8s.io/aws-alb-ingress-controller/pkg/k8s"
22-
"strings"
2324
)
2425

2526
func (b *defaultBuilder) buildLBSecurityGroups(ctx context.Context, stack *LoadBalancingStack,
@@ -137,17 +138,14 @@ func (b *defaultBuilder) buildManagedLBSecurityGroup(ctx context.Context, stack
137138
}
138139
var IPV4CIDRs, IPV6CIDRs []string
139140
for _, cidr := range cidrs {
140-
ip, _, err := net.ParseCIDR(cidr)
141+
_, _, err := net.ParseCIDR(cidr)
141142
if err != nil {
142143
return nil, err
143144
}
144-
switch len(ip) {
145-
case net.IPv4len:
146-
IPV4CIDRs = append(IPV4CIDRs, cidr)
147-
case net.IPv6len:
145+
if strings.Contains(cidr, ":") {
148146
IPV6CIDRs = append(IPV6CIDRs, cidr)
149-
default:
150-
return nil, errors.Errorf("CIDR must use an IPv4 or IPv6 address: %v, Ingress: %v", cidr, ingKey.String())
147+
} else {
148+
IPV4CIDRs = append(IPV4CIDRs, cidr)
151149
}
152150
}
153151
for port, _ := range ingPorts {

pkg/ingress/group_builder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ func (m *defaultGroupBuilder) sortIngresses(ingList []*extensions.Ingress) ([]*e
139139

140140
explicitOrders := sets.NewInt64()
141141
for _, ing := range ingList {
142-
var order = defaultGroupOrder;
142+
var order = defaultGroupOrder
143143
exists, err := m.annotationParser.ParseInt64Annotation(k8s.AnnotationSuffixGroupOrder, &order, ing.Annotations)
144144
if err != nil {
145145
return nil, errors.Wrapf(err, "failed to load ingress group order for ingress: %v", k8s.NamespacedName(ing))

0 commit comments

Comments
 (0)