Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AddVirtualServer (0.12 sec)

  1. pkg/proxy/ipvs/util/ipvs_linux.go

    	if err != nil {
    		klog.ErrorS(err, "IPVS interface can't be initialized")
    		return nil
    	}
    	return &runner{
    		ipvsHandle: handle,
    	}
    }
    
    // AddVirtualServer is part of ipvs.Interface.
    func (runner *runner) AddVirtualServer(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_test.go

    // fakeIpvs implements utilipvs.Interface
    type fakeIpvs struct {
    	ipvsErr   string
    	vsCreated bool
    }
    
    func (f *fakeIpvs) Flush() error {
    	return nil
    }
    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
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier.go

    	logger := klog.FromContext(ctx)
    	// BUG: https://github.com/moby/ipvs/issues/27
    	// If ipvs is not compiled into the kernel no error is returned and handle==nil.
    	// This in turn causes ipvs.GetVirtualServers and ipvs.AddVirtualServer
    	// to return ok (err==nil). If/when this bug is fixed parameter "ipvs" will be nil
    	// if ipvs is not supported by the kernel. Until then a re-read work-around is used.
    	if ipvs == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top