Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cni/pkg/nodeagent/net_test.go

    	fakeIPSetDeps.On("addIP",
    		"foo",
    		netip.MustParseAddr("99.9.9.9"),
    		ipProto,
    		podUID,
    		true,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		podUID,
    		true,
    	).Return(nil)
    
    	podIPs := []netip.Addr{netip.MustParseAddr("99.9.9.9"), netip.MustParseAddr("2.2.2.2")}
    	err := addPodToHostNSIpset(pod, podIPs, &set)
    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)
  2. cni/pkg/iptables/iptables_test.go

    		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")
    
    	for _, tt := range cases {
    		for _, ipv6 := range []bool{false, true} {
    			t.Run(tt.name+"_"+ipstr(ipv6), func(t *testing.T) {
    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)
  3. cni/pkg/nodeagent/server_test.go

    			Name:      "test",
    			Namespace: "test",
    			UID:       types.UID("test"),
    		},
    	}
    
    	fakeCtx := context.Background()
    	fakeClientSet := fake.NewSimpleClientset(pod)
    
    	podIP := netip.MustParseAddr("99.9.9.1")
    	podIPs := []netip.Addr{podIP}
    
    	server := &fakeServer{}
    	server.On("AddPodToMesh",
    		fakeCtx,
    		pod,
    		podIPs,
    		"",
    	).Return(nil)
    
    	server.Start(fakeCtx)
    	m := meshDataplane{
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  4. 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
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/options.go

    	PodName         = env.RegisterStringVar("POD_NAME", "", "").Get()
    	NodeName        = env.RegisterStringVar("NODE_NAME", "", "").Get()
    	Revision        = env.RegisterStringVar("REVISION", "", "").Get()
    	HostProbeSNATIP = netip.MustParseAddr(env.RegisterStringVar("HOST_PROBE_SNAT_IP", DefaultHostProbeSNATIP, "").Get())
    )
    
    const (
    	// to reliably identify kubelet healthprobes from inside the pod (versus standard kube-proxy traffic,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  6. 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,
    		pod,
    		[]netip.Addr{netip.MustParseAddr(fakePodIP)},
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := &meshDataplane{
    		kubeClient: client.Kube(),
    		netServer:  fs,
    	}
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Feb 02 08:18:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  7. api/go1.18.txt

    pkg net/netip, func AddrPortFrom(Addr, uint16) AddrPort
    pkg net/netip, func IPv4Unspecified() Addr
    pkg net/netip, func IPv6LinkLocalAllNodes() Addr
    pkg net/netip, func IPv6Unspecified() Addr
    pkg net/netip, func MustParseAddr(string) Addr
    pkg net/netip, func MustParseAddrPort(string) AddrPort
    pkg net/netip, func MustParsePrefix(string) Prefix
    pkg net/netip, func ParseAddr(string) (Addr, error)
    Plain Text
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 13K bytes
    - Viewed (0)
Back to top