Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for MustParseAddr (0.12 sec)

  1. cni/pkg/nodeagent/server_test.go

    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("99.9.9.9"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	podIPs := []netip.Addr{netip.MustParseAddr("99.9.9.9"), netip.MustParseAddr("2.2.2.2")}
    	_, err := m.addPodToHostNSIpset(pod, podIPs)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables_test.go

    				cfg.RedirectDNS = true
    			},
    		},
    		{
    			name: "ingress",
    			config: func(cfg *Config) {
    			},
    			ingressMode: true,
    		},
    	}
    	probeSNATipv4 := netip.MustParseAddr("169.254.7.127")
    	probeSNATipv6 := netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164")
    
    	for _, tt := range cases {
    		for _, ipv6 := range []bool{false, true} {
    			t.Run(tt.name+"_"+ipstr(ipv6), func(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/options.go

    	NodeName          = env.RegisterStringVar("NODE_NAME", "", "").Get()
    	Revision          = env.RegisterStringVar("REVISION", "", "").Get()
    	HostProbeSNATIP   = netip.MustParseAddr(env.RegisterStringVar("HOST_PROBE_SNAT_IP", DefaultHostProbeSNATIP, "").Get())
    	HostProbeSNATIPV6 = netip.MustParseAddr(env.RegisterStringVar("HOST_PROBE_SNAT_IPV6", DefaultHostProbeSNATIPV6, "").Get())
    )
    
    const (
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	netServer := fixture.netServer
    	ztunnelServer := fixture.ztunnelServer
    	podMeta := metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       "123",
    	}
    	podIP := netip.MustParseAddr("99.9.9.9")
    	podIPs := []netip.Addr{podIP}
    
    	err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns")
    	assert.NoError(t, err)
    	assert.Equal(t, 1, ztunnelServer.addedPods.Load())
    }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. cni/pkg/iptables/iptables_e2e_test.go

    	setup(t)
    	tt := struct {
    		name   string
    		config func(cfg *Config)
    	}{
    		"default",
    		func(cfg *Config) {
    			cfg.RedirectDNS = true
    		},
    	}
    
    	probeSNATipv4 := netip.MustParseAddr("169.254.7.127")
    	probeSNATipv6 := netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164")
    
    	cfg := &Config{}
    	tt.config(cfg)
    
    	deps := &dep.RealDependencies{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. cni/pkg/util/podutil.go

    	var podIPs []netip.Addr
    	if len(pod.Status.PodIPs) != 0 {
    		for _, pip := range pod.Status.PodIPs {
    			ip := netip.MustParseAddr(pip.IP)
    			podIPs = append(podIPs, ip)
    		}
    	} else if len(pod.Status.PodIP) != 0 {
    		ip := netip.MustParseAddr(pod.Status.PodIP)
    		podIPs = append(podIPs, ip)
    	}
    	return podIPs
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/cni-watcher_test.go

    	fs := &fakeServer{testWG: wg}
    
    	// This pod should be enmeshed with the CNI ip, even tho the pod status had no ip
    	fs.On("AddPodToMesh",
    		ctx,
    		mock.IsType(pod),
    		[]netip.Addr{netip.MustParseAddr(fakePodIP)},
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := getFakeDP(fs, client.Kube())
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top