Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for DeleteRealServer (0.34 sec)

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

    	// 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
    	// UpdateRealServer updates the specified real server from the specified virtual server.
    	UpdateRealServer(*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.go

    		return nil, fmt.Errorf("failed to get destinations for service %v, service not found", key.String())
    	}
    	return f.Destinations[key], nil
    }
    
    // DeleteRealServer is a fake implementation, it deletes the real server in the cache store.
    func (f *FakeIPVS) DeleteRealServer(serv *utilipvs.VirtualServer, dest *utilipvs.RealServer) error {
    	if serv == nil || dest == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 7K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/util/testing/fake_test.go

    		}
    		if len(list) != rssLen {
    			t.Errorf("Expect %d virtual servers, got: %d", len(rss), len(list))
    		}
    		rsToDel := list[i]
    		if err = fake.DeleteRealServer(vs, rsToDel); err != nil {
    			t.Errorf("Fail to delete real server of the virtual server, error: %v", err)
    		} else {
    			dests, err := fake.GetRealServers(vs)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/util/ipvs_linux.go

    	}
    	runner.mu.Lock()
    	defer runner.mu.Unlock()
    	return runner.ipvsHandle.NewDestination(svc, dst)
    }
    
    // DeleteRealServer is part of ipvs.Interface.
    func (runner *runner) DeleteRealServer(vs *VirtualServer, rs *RealServer) error {
    	svc, err := toIPVSService(vs)
    	if err != nil {
    		return 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/graceful_termination.go

    				return false, nil
    			}
    			klog.V(5).InfoS("Deleting real server", "realServer", rsToDelete)
    			err := m.ipvs.DeleteRealServer(rsToDelete.VirtualServer, rs)
    			if err != nil {
    				return false, fmt.Errorf("delete destination %q err: %w", rs.String(), err)
    			}
    			return true, nil
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier_test.go

    	return nil
    }
    func (f *fakeIpvs) GetRealServers(*utilipvs.VirtualServer) ([]*utilipvs.RealServer, error) {
    	return nil, nil
    }
    func (f *fakeIpvs) DeleteRealServer(*utilipvs.VirtualServer, *utilipvs.RealServer) error {
    	return nil
    }
    func (f *fakeIpvs) UpdateRealServer(*utilipvs.VirtualServer, *utilipvs.RealServer) error {
    	return 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