Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Addr (0.32 sec)

  1. cni/pkg/ipset/nldeps_unspecified.go

    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) clearEntriesWithIP(name string, ip netip.Addr) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) listEntriesByIP(name string) ([]netip.Addr, error) {
    	return []netip.Addr{}, errors.New("not implemented on this platform")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  2. cni/pkg/ipset/nldeps_linux.go

    }
    
    func (m *realDeps) listEntriesByIP(name string) ([]netip.Addr, error) {
    	var ipList []netip.Addr
    
    	res, err := netlink.IpsetList(name)
    	if err != nil {
    		return ipList, fmt.Errorf("failed to list ipset %s: %w", name, err)
    	}
    
    	for _, entry := range res.Entries {
    		addr, _ := netip.AddrFromSlice(entry.IP)
    		ipList = append(ipList, addr)
    	}
    
    	return ipList, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_mock.go

    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) clearEntriesWithIP(name string, ip netip.Addr) error {
    	args := m.Called(name, ip)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) listEntriesByIP(name string) ([]netip.Addr, error) {
    	args := m.Called(name)
    	return args.Get(0).([]netip.Addr), args.Error(1)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	ztunnelServer := fixture.ztunnelServer
    	podMeta := metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       "123",
    	}
    	podIP := netip.MustParseAddr("99.9.9.9")
    	podIPs := []netip.Addr{podIP}
    
    	fixture.ipsetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("99.9.9.9"),
    		uint8(unix.IPPROTO_TCP),
    		string(podMeta.UID),
    		true,
    	).Return(nil)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    	}
    
    	return nil
    }
    
    func pruneHostIPset(expected sets.Set[netip.Addr], hostsideProbeSet *ipset.IPSet) error {
    	actualIPSetContents, err := hostsideProbeSet.ListEntriesByIP()
    	if err != nil {
    		log.Warnf("unable to list IPSet: %v", err)
    		return err
    	}
    	actual := sets.New[netip.Addr](actualIPSetContents...)
    	stales := actual.DifferenceInPlace(expected)
    
    	for staleIP := range stales {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  6. cni/pkg/nodeagent/server.go

    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error
    	DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error
    
    	Stop()
    }
    
    type Server struct {
    	ctx        context.Context
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  7. cni/pkg/ipset/ipset.go

    	destroySet(name string) error
    	addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error
    	deleteIP(name string, ip netip.Addr, ipProto uint8) error
    	flush(name string) error
    	clearEntriesWithComment(name string, comment string) error
    	clearEntriesWithIP(name string, ip netip.Addr) error
    	listEntriesByIP(name string) ([]netip.Addr, error)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  8. cni/pkg/iptables/iptables.go

    // Setup iptables rules for in-pod mode. Ideally this should be an idempotent function.
    // NOTE that this expects to be run from within the pod network namespace!
    func (cfg *IptablesConfigurator) CreateInpodRules(hostProbeSNAT *netip.Addr) error {
    	// Append our rules here
    	builder := cfg.appendInpodRules(hostProbeSNAT)
    
    	if err := cfg.addLoopbackRoute(); err != nil {
    		return err
    	}
    
    	if err := cfg.addInpodMarkIPRule(); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  9. cni/pkg/iptables/iptables_test.go

    				cfg := constructTestConfig()
    				cfg.EnableIPv6 = 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)
    				if err != nil {
    					t.Fatal(err)
    				}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  10. manifests/charts/istio-control/istio-discovery/files/waypoint.yaml

              valueFrom:
                fieldRef:
                  fieldPath: spec.nodeName
            - name: PILOT_CERT_PROVIDER
              value: {{ .Values.global.pilotCertProvider }}
            - name: CA_ADDR
            {{- if .Values.global.caAddress }}
              value: {{ .Values.global.caAddress }}
            {{- else }}
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 10.1K bytes
    - Viewed (0)
Back to top