- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for DeleteVirtualServer (0.28 sec)
-
pkg/proxy/ipvs/util/ipvs.go
// UpdateVirtualServer updates an already existing virtual server. If the virtual server does not exist, return error. UpdateVirtualServer(*VirtualServer) error // DeleteVirtualServer deletes the specified virtual server. If the virtual server does not exist, return error. DeleteVirtualServer(*VirtualServer) error // Given a partial virtual server, GetVirtualServer will return the specified virtual server information in the system.
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
} key := toServiceKey(serv) f.Services[key] = serv return nil } // DeleteVirtualServer is a fake implementation, it simply deletes the VirtualServer from the cache store. func (f *FakeIPVS) DeleteVirtualServer(serv *utilipvs.VirtualServer) error { if serv == nil { return fmt.Errorf("failed to delete service: service can't be nil") } key := toServiceKey(serv)
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 err != nil { t.Errorf("Fail to list virtual servers, error: %v", err) } if len(list) != 3 { t.Errorf("Expect 2 virtual servers, got: %d", len(list)) } // Delete a virtual server err = fake.DeleteVirtualServer(vs1) if err != nil { t.Errorf("Fail to delete virtual server: %v, error: %v", vs1, err) } // Check the deleted virtual server no longer exists got, _ := fake.GetVirtualServer(vs1) if got != 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.UpdateService(svc) } // DeleteVirtualServer is part of ipvs.Interface. func (runner *runner) DeleteVirtualServer(vs *VirtualServer) error { svc, err := toIPVSService(vs) if err != nil { return fmt.Errorf("could not convert local virtual server to IPVS service: %w", err) } runner.mu.Lock()
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/proxier.go
logger.Info("Dummy VS not created", "scheduler", scheduler) return fmt.Errorf("Ipvs not supported") // This is a BUG work-around } logger.V(5).Info("Dummy VS created", "vs", vs) if err := ipvs.DeleteVirtualServer(&vs); err != nil { logger.Error(err, "Could not delete dummy VS") return err } return nil } // CleanupIptablesLeftovers removes all iptables rules and chains created by the Proxier
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
return fmt.Errorf("oops") } f.vsCreated = true return nil } func (f *fakeIpvs) UpdateVirtualServer(*utilipvs.VirtualServer) error { return nil } func (f *fakeIpvs) DeleteVirtualServer(*utilipvs.VirtualServer) error { if f.ipvsErr == "DeleteVirtualServer" { return fmt.Errorf("oops") } return nil } func (f *fakeIpvs) GetVirtualServer(*utilipvs.VirtualServer) (*utilipvs.VirtualServer, error) { return nil, 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)