- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for DeleteRealServer (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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)