Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for FilterRules (0.34 sec)

  1. 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)
  2. pkg/proxy/ipvs/proxier.go

    	proxier.iptablesData.Write(proxier.filterChains.Bytes())
    	proxier.iptablesData.Write(proxier.filterRules.Bytes())
    
    	proxier.logger.V(5).Info(
    		"Restoring iptables", "natChains", proxier.natChains,
    		"natRules", proxier.natRules, "filterChains", proxier.filterChains,
    		"filterRules", proxier.filterRules)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top