Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for EnsureDummyDevice (0.25 sec)

  1. pkg/proxy/ipvs/netlink.go

    	// UnbindAddress unbind address from the interface
    	UnbindAddress(address, devName string) error
    	// EnsureDummyDevice checks if dummy device is exist and, if not, create one.  If the dummy device is already exist, return true.
    	EnsureDummyDevice(devName string) (exist bool, err error)
    	// DeleteDummyDevice deletes the given dummy device by name.
    	DeleteDummyDevice(devName string) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 27 19:02:20 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/testing/fake.go

    		}
    	}
    	// return error message if address is not found in slice h.localAddresses[devName]
    	return fmt.Errorf("address: %s is not found in interface: %s", address, devName)
    }
    
    // EnsureDummyDevice is a mock implementation
    func (h *FakeNetlinkHandle) EnsureDummyDevice(devName string) (bool, error) {
    	if len(devName) == 0 {
    		return false, fmt.Errorf("device name can't be empty")
    	}
    	if _, ok := h.localAddresses[devName]; !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/netlink_linux.go

    		if err != unix.ENXIO {
    			return fmt.Errorf("error unbind address: %s from interface: %s, err: %v", address, devName, err)
    		}
    	}
    	return nil
    }
    
    // EnsureDummyDevice is part of interface
    func (h *netlinkHandle) EnsureDummyDevice(devName string) (bool, error) {
    	_, err := h.LinkByName(devName)
    	if err == nil {
    		// found dummy device
    		return true, nil
    	}
    	dummy := &netlink.Dummy{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 30 16:18:49 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    	proxier.natChains.Write("*nat")
    
    	proxier.createAndLinkKubeChain()
    
    	// make sure dummy interface exists in the system where ipvs Proxier will bind service address on it
    	_, err := proxier.netlinkHandle.EnsureDummyDevice(defaultDummyDevice)
    	if err != nil {
    		proxier.logger.Error(err, "Failed to create dummy interface", "interface", defaultDummyDevice)
    		return
    	}
    
    	// make sure ip sets exists in the system.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier_test.go

    		ipt := iptablestest.NewFake()
    		ipvs := ipvstest.NewFake()
    		ipset := ipsettest.NewFake(testIPSetVersion)
    		proxier := NewFakeProxier(ctx, ipt, ipvs, ipset, nil, nil, v1.IPv4Protocol)
    
    		proxier.netlinkHandle.EnsureDummyDevice(defaultDummyDevice)
    		if testCases[i].oldVirtualServer != nil {
    			if err := proxier.ipvs.AddVirtualServer(testCases[i].oldVirtualServer); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
Back to top