Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for addIP (0.15 sec)

  1. cni/pkg/nodeagent/net_test.go

    	fakeIPSetDeps := ipset.FakeNLDeps()
    	set := ipset.IPSet{Name: "foo", Deps: fakeIPSetDeps}
    	ipProto := uint8(unix.IPPROTO_TCP)
    
    	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)
    
    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/ipset/ipset.go

    	}
    	err := deps.ipsetIPPortCreate(name)
    	return set, err
    }
    
    func (m *IPSet) DestroySet() error {
    	return m.Deps.destroySet(m.Name)
    }
    
    func (m *IPSet) AddIP(ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	return m.Deps.addIP(m.Name, ip, ipProto, comment, replace)
    }
    
    func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error {
    	return m.Deps.deleteIP(m.Name, ip, ipProto)
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_unspecified.go

    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. cni/pkg/ipset/nldeps_mock.go

    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) destroySet(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	args := m.Called(name, ip, ipProto, comment, replace)
    	return args.Error(0)
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_linux.go

    		return nil
    	}
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	err := netlink.IpsetAdd(name, &netlink.IPSetEntry{
    		Comment:  comment,
    		IP:       net.IP(ip.Unmap().AsSlice()),
    		Protocol: &ipProto,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    		// Add IP/port combo to set. Note that we set Replace to true - a pod ip/port combo already being
    		// in the set is perfectly fine, and something we can always safely overwrite, so we will.
    		if err := hostsideProbeSet.AddIP(pip, ipProto, podUID, true); err != nil {
    			ipsetAddrErrs = append(ipsetAddrErrs, err)
    			log.Warnf("failed adding pod %s to ipset %s with ip %s, error was %s",
    				pod.Name, hostsideProbeSet.Name, pip, err)
    		}
    	}
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.1K bytes
    - Viewed (1)
Back to top