mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-01 07:47:56 +00:00
Fix typo: Ingess -> Ingress
This commit is contained in:
parent
0f1c4c25c3
commit
e32c66c6f4
@ -1463,7 +1463,7 @@ func isEqualIPPermission(l, r *ec2.IPPermission) bool {
|
|||||||
// Makes sure the security group includes the specified permissions
|
// Makes sure the security group includes the specified permissions
|
||||||
// Returns true iff changes were made
|
// Returns true iff changes were made
|
||||||
// The security group must already exist
|
// The security group must already exist
|
||||||
func (s *AWSCloud) ensureSecurityGroupIngess(securityGroupId string, addPermissions []*ec2.IPPermission) (bool, error) {
|
func (s *AWSCloud) ensureSecurityGroupIngress(securityGroupId string, addPermissions []*ec2.IPPermission) (bool, error) {
|
||||||
group, err := s.findSecurityGroup(securityGroupId)
|
group, err := s.findSecurityGroup(securityGroupId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.Warning("error retrieving security group", err)
|
glog.Warning("error retrieving security group", err)
|
||||||
@ -1510,7 +1510,7 @@ func (s *AWSCloud) ensureSecurityGroupIngess(securityGroupId string, addPermissi
|
|||||||
// Makes sure the security group no longer includes the specified permissions
|
// Makes sure the security group no longer includes the specified permissions
|
||||||
// Returns true iff changes were made
|
// Returns true iff changes were made
|
||||||
// Returns true if the security group no longer exists
|
// Returns true if the security group no longer exists
|
||||||
func (s *AWSCloud) removeSecurityGroupIngess(securityGroupId string, removePermissions []*ec2.IPPermission) (bool, error) {
|
func (s *AWSCloud) removeSecurityGroupIngress(securityGroupId string, removePermissions []*ec2.IPPermission) (bool, error) {
|
||||||
group, err := s.findSecurityGroup(securityGroupId)
|
group, err := s.findSecurityGroup(securityGroupId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.Warning("error retrieving security group", err)
|
glog.Warning("error retrieving security group", err)
|
||||||
@ -1697,7 +1697,7 @@ func (s *AWSCloud) CreateTCPLoadBalancer(name, region string, publicIP net.IP, p
|
|||||||
|
|
||||||
permissions = append(permissions, permission)
|
permissions = append(permissions, permission)
|
||||||
}
|
}
|
||||||
_, err = s.ensureSecurityGroupIngess(securityGroupID, permissions)
|
_, err = s.ensureSecurityGroupIngress(securityGroupID, permissions)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@ -1927,7 +1927,7 @@ func (s *AWSCloud) updateInstanceSecurityGroupsForLoadBalancer(lb *elb.LoadBalan
|
|||||||
permissions := []*ec2.IPPermission{permission}
|
permissions := []*ec2.IPPermission{permission}
|
||||||
|
|
||||||
if add {
|
if add {
|
||||||
changed, err := s.ensureSecurityGroupIngess(instanceSecurityGroupId, permissions)
|
changed, err := s.ensureSecurityGroupIngress(instanceSecurityGroupId, permissions)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@ -1935,7 +1935,7 @@ func (s *AWSCloud) updateInstanceSecurityGroupsForLoadBalancer(lb *elb.LoadBalan
|
|||||||
glog.Warning("allowing ingress was not needed; concurrent change? groupId=", instanceSecurityGroupId)
|
glog.Warning("allowing ingress was not needed; concurrent change? groupId=", instanceSecurityGroupId)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
changed, err := s.removeSecurityGroupIngess(instanceSecurityGroupId, permissions)
|
changed, err := s.removeSecurityGroupIngress(instanceSecurityGroupId, permissions)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user