- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for UpdateVirtualServer (0.2 sec)
-
pkg/proxy/ipvs/util/ipvs.go
Flush() error // AddVirtualServer creates the specified virtual server. AddVirtualServer(*VirtualServer) error // 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.
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
// make sure no destination present when creating new service f.Destinations[key] = make([]*utilipvs.RealServer, 0) return nil } // UpdateVirtualServer is a fake implementation, it updates the VirtualServer in the cache store. func (f *FakeIPVS) UpdateVirtualServer(serv *utilipvs.VirtualServer) error { if serv == nil { return fmt.Errorf("failed to update 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/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/util/testing/fake_test.go
// Update virtual server vs12 := &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("1.2.3.4"), Port: uint16(80), Protocol: string("TCP"), Flags: utilipvs.FlagPersistent, } err = fake.UpdateVirtualServer(vs12) if err != nil { t.Errorf("Fail to update virtual server, error: %v", err) } // Check the updated virtual server got12, err := fake.GetVirtualServer(vs1) 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/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)