Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for UpdateVirtualServer (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top