- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for FilterRules (0.34 sec)
-
pkg/proxy/iptables/proxier.go
filterChains := proxyutil.NewLineBuffer() filterRules := proxyutil.NewLineBuffer() filterChains.Write("*filter") for _, chain := range []utiliptables.Chain{kubeServicesChain, kubeExternalServicesChain, kubeForwardChain, kubeNodePortsChain} { if existingFilterChains.Has(chain) { chainString := string(chain) filterChains.Write(utiliptables.MakeChainLine(chain)) filterRules.Write("-X", chainString) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
for _, otherRule := range otherRules { if lc.Rules[i].ID == otherRule.ID { return errLifecycleDuplicateID } } } return nil } // FilterRules returns the rules filtered by the status, prefix and tags func (lc Lifecycle) FilterRules(obj ObjectOpts) []Rule { if obj.Name == "" { return nil } var rules []Rule for _, rule := range lc.Rules { if rule.Status == Disabled { continue
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
fp.syncProxyRules() t.Logf("time to sync rule: %v", time.Since(now)) t.Logf("iptables data size: %d bytes", fp.iptablesData.Len()) if fp.filterRules.Lines() != test.expectedFilterRules { t.Errorf("expected number of Filter rules: %d, got: %d", test.expectedFilterRules, fp.filterRules.Lines()) } if fp.natRules.Lines() != test.expectedNatRules {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
IsLatest: true, NumVersions: 1, }, want: 0, lc: lc, }, } for i, tc := range tests { t.Run(fmt.Sprintf("test-%d", i+1), func(t *testing.T) { if got := tc.lc.FilterRules(tc.opts); len(got) != tc.want { t.Fatalf("Expected %d rules to match but got %d", tc.want, len(got)) } w := httptest.NewRecorder() tc.lc.SetPredictionHeaders(w, tc.opts)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 55.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
filterChainsData: bytes.NewBuffer(nil), natChains: proxyutil.NewLineBuffer(), natRules: proxyutil.NewLineBuffer(), filterChains: proxyutil.NewLineBuffer(), filterRules: proxyutil.NewLineBuffer(), netlinkHandle: netlinkHandle, ipsetList: ipsetList, nodePortAddresses: proxyutil.NewNodePortAddresses(ipFamily, nil),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/proxy/iptables/proxier_test.go
precomputedProbabilities: make([]string, 0, 1001), iptablesData: bytes.NewBuffer(nil), existingFilterChainsData: bytes.NewBuffer(nil), filterChains: proxyutil.NewLineBuffer(), filterRules: proxyutil.NewLineBuffer(), natChains: proxyutil.NewLineBuffer(), natRules: proxyutil.NewLineBuffer(), nodeIP: netutils.ParseIPSloppy(testNodeIP),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (1)