Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewIptablesConfigurator (0.23 sec)

  1. cni/pkg/iptables/iptables_test.go

    			t.Run(tt.name+"_"+ipstr(ipv6), func(t *testing.T) {
    				cfg := constructTestConfig()
    				cfg.EnableInboundIPv6 = ipv6
    				tt.config(cfg)
    				ext := &dep.DependenciesStub{}
    				iptConfigurator, _ := NewIptablesConfigurator(cfg, ext, EmptyNlDeps())
    				var probeIP *netip.Addr
    				if ipv6 {
    					probeIP = &probeSNATipv6
    				} else {
    					probeIP = &probeSNATipv4
    				}
    				err := iptConfigurator.CreateInpodRules(probeIP)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 17:46:23 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    		return nil, fmt.Errorf("error initializing the ztunnel server: %w", err)
    	}
    
    	cfg := &iptables.Config{
    		RestoreFormat: true,
    		RedirectDNS:   args.DNSCapture,
    	}
    
    	iptablesConfigurator, err := iptables.NewIptablesConfigurator(cfg, realDependencies(), iptables.RealNlDeps())
    	if err != nil {
    		return nil, fmt.Errorf("error configuring iptables: %w", err)
    	}
    
    	// Create hostprobe rules now, in the host netns
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net_test.go

    }
    
    func getTestFixure(ctx context.Context) netTestFixture {
    	podNsMap := newPodNetnsCache(openNsTestOverride)
    	nlDeps := &fakeIptablesDeps{}
    	iptablesConfigurator, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, nlDeps)
    
    	ztunnelServer := &fakeZtunnel{}
    
    	fakeIPSetDeps := ipset.FakeNLDeps()
    	set := ipset.IPSet{Name: "foo", Deps: fakeIPSetDeps}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 14.3K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables.go

    	return &iptablesconfig.Config{
    		RestoreFormat:     c.RestoreFormat,
    		TraceLogging:      c.TraceLogging,
    		EnableInboundIPv6: c.EnableInboundIPv6,
    		RedirectDNS:       c.RedirectDNS,
    	}
    }
    
    func NewIptablesConfigurator(cfg *Config, ext dep.Dependencies, nlDeps NetlinkDependencies) (*IptablesConfigurator, error) {
    	if cfg == nil {
    		cfg = &Config{
    			RestoreFormat: true,
    		}
    	}
    
    	configurator := &IptablesConfigurator{
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 19.2K bytes
    - Viewed (0)
Back to top