@@ -122,7 +122,7 @@ type hnsNetworkInfo struct {
122
122
123
123
type remoteSubnetInfo struct {
124
124
destinationPrefix string
125
- isolationId uint16
125
+ isolationID uint16
126
126
providerAddress string
127
127
drMacAddress string
128
128
}
@@ -649,13 +649,13 @@ func (svcInfo *serviceInfo) deleteAllHnsLoadBalancerPolicy() {
649
649
hns .deleteLoadBalancer (svcInfo .nodePorthnsID )
650
650
svcInfo .nodePorthnsID = ""
651
651
652
- for _ , externalIp := range svcInfo .externalIPs {
653
- hns .deleteLoadBalancer (externalIp .hnsID )
654
- externalIp .hnsID = ""
652
+ for _ , externalIP := range svcInfo .externalIPs {
653
+ hns .deleteLoadBalancer (externalIP .hnsID )
654
+ externalIP .hnsID = ""
655
655
}
656
- for _ , lbIngressIp := range svcInfo .loadBalancerIngressIPs {
657
- hns .deleteLoadBalancer (lbIngressIp .hnsID )
658
- lbIngressIp .hnsID = ""
656
+ for _ , lbIngressIP := range svcInfo .loadBalancerIngressIPs {
657
+ hns .deleteLoadBalancer (lbIngressIP .hnsID )
658
+ lbIngressIP .hnsID = ""
659
659
}
660
660
}
661
661
@@ -764,8 +764,8 @@ func shouldSkipService(svcName types.NamespacedName, service *v1.Service) bool {
764
764
func (proxier * Proxier ) updateServiceMap () (result updateServiceMapResult ) {
765
765
result .staleServices = sets .NewString ()
766
766
767
- var serviceMap proxyServiceMap = proxier .serviceMap
768
- var changes * serviceChangeMap = & proxier .serviceChanges
767
+ serviceMap : = proxier .serviceMap
768
+ changes : = & proxier .serviceChanges
769
769
770
770
func () {
771
771
changes .lock .Lock ()
@@ -826,8 +826,8 @@ func (proxier *Proxier) updateEndpointsMap() (result updateEndpointMapResult) {
826
826
result .staleEndpoints = make (map [endpointServicePair ]bool )
827
827
result .staleServiceNames = make (map [proxy.ServicePortName ]bool )
828
828
829
- var endpointsMap proxyEndpointsMap = proxier .endpointsMap
830
- var changes * endpointsChangeMap = & proxier .endpointsChanges
829
+ endpointsMap : = proxier .endpointsMap
830
+ changes : = & proxier .endpointsChanges
831
831
832
832
func () {
833
833
changes .lock .Lock ()
@@ -1150,14 +1150,14 @@ func (proxier *Proxier) syncProxyRules() {
1150
1150
}
1151
1151
1152
1152
// Create a Load Balancer Policy for each external IP
1153
- for _ , externalIp := range svcInfo .externalIPs {
1153
+ for _ , externalIP := range svcInfo .externalIPs {
1154
1154
// Try loading existing policies, if already available
1155
1155
hnsLoadBalancer , err = hns .getLoadBalancer (
1156
1156
hnsEndpoints ,
1157
1157
false ,
1158
1158
false ,
1159
1159
sourceVip ,
1160
- externalIp .ip ,
1160
+ externalIP .ip ,
1161
1161
Enum (svcInfo .protocol ),
1162
1162
uint16 (svcInfo .targetPort ),
1163
1163
uint16 (svcInfo .port ),
@@ -1166,18 +1166,18 @@ func (proxier *Proxier) syncProxyRules() {
1166
1166
klog .Errorf ("Policy creation failed: %v" , err )
1167
1167
continue
1168
1168
}
1169
- externalIp .hnsID = hnsLoadBalancer .hnsID
1170
- klog .V (3 ).Infof ("Hns LoadBalancer resource created for externalIp resources %v, Id[%s]" , externalIp , hnsLoadBalancer .hnsID )
1169
+ externalIP .hnsID = hnsLoadBalancer .hnsID
1170
+ klog .V (3 ).Infof ("Hns LoadBalancer resource created for externalIP resources %v, Id[%s]" , externalIP , hnsLoadBalancer .hnsID )
1171
1171
}
1172
1172
// Create a Load Balancer Policy for each loadbalancer ingress
1173
- for _ , lbIngressIp := range svcInfo .loadBalancerIngressIPs {
1173
+ for _ , lbIngressIP := range svcInfo .loadBalancerIngressIPs {
1174
1174
// Try loading existing policies, if already available
1175
1175
hnsLoadBalancer , err := hns .getLoadBalancer (
1176
1176
hnsEndpoints ,
1177
1177
false ,
1178
1178
false ,
1179
1179
sourceVip ,
1180
- lbIngressIp .ip ,
1180
+ lbIngressIP .ip ,
1181
1181
Enum (svcInfo .protocol ),
1182
1182
uint16 (svcInfo .targetPort ),
1183
1183
uint16 (svcInfo .port ),
@@ -1186,8 +1186,8 @@ func (proxier *Proxier) syncProxyRules() {
1186
1186
klog .Errorf ("Policy creation failed: %v" , err )
1187
1187
continue
1188
1188
}
1189
- lbIngressIp .hnsID = hnsLoadBalancer .hnsID
1190
- klog .V (3 ).Infof ("Hns LoadBalancer resource created for loadBalancer Ingress resources %v" , lbIngressIp )
1189
+ lbIngressIP .hnsID = hnsLoadBalancer .hnsID
1190
+ klog .V (3 ).Infof ("Hns LoadBalancer resource created for loadBalancer Ingress resources %v" , lbIngressIP )
1191
1191
}
1192
1192
svcInfo .policyApplied = true
1193
1193
Log (svcInfo , "+++Policy Successfully applied for service +++" , 2 )
0 commit comments