@@ -63,10 +63,10 @@ func (k *K8sSWIFTv2Middleware) IPConfigsRequestHandlerWrapper(defaultHandler, fa
6363 for i := range ipConfigsResp .PodIPInfo {
6464 ipInfo := & ipConfigsResp .PodIPInfo [i ]
6565 // there will be no pod connectivity to and from those pods
66- var defaultDenyEngressPolicy , defaultDenyIngressPolicy policy.Policy
66+ var defaultDenyEgressPolicy , defaultDenyIngressPolicy policy.Policy
6767
6868 if defaultDenyACLbool && ipInfo .NICType == cns .InfraNIC {
69- defaultDenyEngressPolicy , err = getEndpointPolicy (string (policy .ACLPolicy ), cns .ActionTypeBlock , cns .DirectionTypeOut , 10_000 )
69+ defaultDenyEgressPolicy , err = getEndpointPolicy (string (policy .ACLPolicy ), cns .ActionTypeBlock , cns .DirectionTypeOut , 10_000 )
7070 if err != nil {
7171 logger .Errorf ("failed to add default deny acl's for pod %v with err %v" , podInfo .Name (), err )
7272 }
@@ -76,8 +76,8 @@ func (k *K8sSWIFTv2Middleware) IPConfigsRequestHandlerWrapper(defaultHandler, fa
7676 logger .Errorf ("failed to add default deny acl's for pod %v with err %v" , podInfo .Name (), err )
7777 }
7878
79- ipInfo .EndpointPolicies = append (ipInfo .EndpointPolicies , defaultDenyEngressPolicy , defaultDenyIngressPolicy )
80- logger .Printf ("Created endpoint policies for defaultDenyEngressPolicy and defaultDenyIngressPolicy" )
79+ ipInfo .EndpointPolicies = append (ipInfo .EndpointPolicies , defaultDenyEgressPolicy , defaultDenyIngressPolicy )
80+ logger .Printf ("Created endpoint policies for defaultDenyEgressPolicy and defaultDenyIngressPolicy" )
8181
8282 break
8383 }
0 commit comments