- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ruleExists (0.09 sec)
-
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
for i := range clusterRoles { if clusterRoles[i].Name == sharedClusterRole.Name { continue } for j := range clusterRoles[i].Rules { currRule := clusterRoles[i].Rules[j] if !ruleExists(newPolicyRules, currRule) { newPolicyRules = append(newPolicyRules, currRule) } } } } if equality.Semantic.DeepEqual(newPolicyRules, sharedClusterRole.Rules) { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
Protocol: ptr.To(v1.ProtocolTCP), }} }), ) fp.syncProxyRules() element := nft.Table.Maps["service-ips"].FindElement(testCase.svcLBIP, "tcp", "80") ruleExists := element != nil if ruleExists != testCase.expectedRule { t.Errorf("unexpected rule for %s", testCase.svcLBIP) } }) } } func Test_servicePortChainNameBase(t *testing.T) { testCases := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier_test.go
) fp.syncProxyRules() c, _ := ipt.Dump.GetChain(utiliptables.TableNAT, kubeServicesChain) ruleExists := false for _, r := range c.Rules { if r.DestinationAddress != nil && r.DestinationAddress.Value == testCase.svcLBIP { ruleExists = true } } if ruleExists != testCase.expectedRule { t.Errorf("unexpected rule for %s", testCase.svcLBIP) } }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (0)