Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cni/pkg/nodeagent/server_test.go

    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("3.3.3.3"),
    		ipProto,
    		pod1UID,
    		false,
    	).Return(errors.New("CANNOT ADD"))
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		pod1UID,
    		false,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("3.3.3.3"),
    		ipProto,
    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/ipset/ipset.go

    		err = errors.Join(err, v6err)
    	}
    	return err
    }
    
    func (m *IPSet) AddIP(ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	ipToInsert := ip.Unmap()
    
    	// We have already Unmap'd, so we can do a simple IsV6 y/n check now
    	if ipToInsert.Is6() {
    		return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace)
    	}
    	return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_mock.go

    	args := m.Called(name, v6)
    	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)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. 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 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 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.AsSlice()),
    		Protocol: &ipProto,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 18 23:53:18 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/server.go

    		// we _shouldn't_ get any overwrite/overlap, unless something is wrong and we are asked to add
    		// a pod by an IP we already have in the set (which will give an error, which we want).
    		if err := s.hostsideProbeIPSet.AddIP(pip, ipProto, podUID, false); err != nil {
    			ipsetAddrErrs = append(ipsetAddrErrs, err)
    			log.Errorf("failed adding pod %s to ipset %s with ip %s, error was %s",
    				pod.Name, &s.hostsideProbeIPSet.Prefix, pip, err)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top