- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetRealServers (0.43 sec)
-
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) -
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) -
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) -
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) -
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)