- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for UpdateVirtualServer (0.14 sec)
-
pkg/proxy/ipvs/util/ipvs_linux.go
} runner.mu.Lock() defer runner.mu.Unlock() return runner.ipvsHandle.NewService(svc) } // UpdateVirtualServer is part of ipvs.Interface. func (runner *runner) UpdateVirtualServer(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
// IPVS service was changed, update the existing one // During updates, service VIP will not go down proxier.logger.V(3).Info("IPVS service was changed", "serviceName", svcName) if err := proxier.ipvs.UpdateVirtualServer(vs); err != nil { proxier.logger.Error(err, "Failed to update IPVS service") return err } } } // bind service address to dummy interface if bindAddr {
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
} func (f *fakeIpvs) AddVirtualServer(*utilipvs.VirtualServer) error { if f.ipvsErr == "AddVirtualServer" { 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0)