Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetRealServers (0.26 sec)

  1. pkg/proxy/ipvs/util/ipvs.go

    	GetVirtualServers() ([]*VirtualServer, error)
    	// AddRealServer creates the specified real server for the specified virtual server.
    	AddRealServer(*VirtualServer, *RealServer) error
    	// GetRealServers returns all real servers for the specified virtual server.
    	GetRealServers(*VirtualServer) ([]*RealServer, error)
    	// DeleteRealServer deletes the specified real server from the specified virtual server.
    	DeleteRealServer(*VirtualServer, *RealServer) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/util/testing/fake_test.go

    	// Delete a real server of the virtual server
    	// Make sure any position of the list can be real deleted
    	rssLen := len(rss)
    	for i := range rss {
    		// List all real servers of the virtual server
    		list, err := fake.GetRealServers(vs)
    		if err != nil {
    			t.Errorf("Fail to get real servers of the virtual server, error: %v", err)
    		}
    		if len(list) != rssLen {
    			t.Errorf("Expect %d virtual servers, got: %d", len(rss), len(list))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/util/testing/fake.go

    	// The tests assumes that the slice is sorted
    	sort.Sort(byAddress(f.Destinations[key]))
    	return nil
    }
    
    // GetRealServers is a fake implementation, it simply returns all RealServers in the cache store.
    func (f *FakeIPVS) GetRealServers(serv *utilipvs.VirtualServer) ([]*utilipvs.RealServer, error) {
    	if serv == nil {
    		return nil, fmt.Errorf("failed to get destination for nil service")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 7K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/util/ipvs_linux.go

    	}
    	runner.mu.Lock()
    	defer runner.mu.Unlock()
    	return runner.ipvsHandle.UpdateDestination(svc, dst)
    }
    
    // GetRealServers is part of ipvs.Interface.
    func (runner *runner) GetRealServers(vs *VirtualServer) ([]*RealServer, error) {
    	svc, err := toIPVSService(vs)
    	if err != nil {
    		return nil, fmt.Errorf("could not convert local virtual server to IPVS service: %w", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 9K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier_test.go

    			externalIPServer = virtualServer
    		}
    	}
    
    	realServers1, rsErr1 = ipvs.GetRealServers(clusterIPServer)
    	assert.Nil(t, rsErr1, "Expected no error getting real servers")
    	assert.Len(t, realServers1, 0, "Expected 0 real servers")
    
    	realServers2, rsErr2 = ipvs.GetRealServers(externalIPServer)
    	assert.Nil(t, rsErr2, "Expected no error getting real servers")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/graceful_termination.go

    	return nil
    }
    
    func (m *GracefulTerminationManager) deleteRsFunc(rsToDelete *listItem) (bool, error) {
    	klog.V(5).InfoS("Trying to delete real server", "realServer", rsToDelete)
    	rss, err := m.ipvs.GetRealServers(rsToDelete.VirtualServer)
    	if err != nil {
    		return false, err
    	}
    	for _, rs := range rss {
    		if rsToDelete.RealServer.Equal(rs) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  7. pkg/proxy/ipvs/proxier.go

    		return errors.New("IPVS virtual service does not exist")
    	}
    
    	// curEndpoints represents IPVS destinations listed from current system.
    	curEndpoints := sets.New[string]()
    	curDests, err := proxier.ipvs.GetRealServers(appliedVirtualServer)
    	if err != nil {
    		proxier.logger.Error(err, "Failed to list IPVS destinations")
    		return err
    	}
    	for _, des := range curDests {
    		curEndpoints.Insert(des.String())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top