Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for addMap (0.24 sec)

  1. cni/pkg/nodeagent/net_test.go

    	set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps}
    	ipProto := uint8(unix.IPPROTO_TCP)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("99.9.9.9"),
    		ipProto,
    		podUID,
    		true,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		podUID,
    		true,
    	).Return(nil)
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  2. 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)
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  3. 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,
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. 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.Prefix, pip, err)
    		}
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  5. 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 May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  6. 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)
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
Back to top