Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AddVirtualServer (0.2 sec)

  1. pkg/proxy/ipvs/util/testing/fake_test.go

    		Protocol: string("UDP"),
    	}
    	err = fake.AddVirtualServer(vs2)
    	if err != nil {
    		t.Errorf("Unexpected error when add virtual server, error: %v", err)
    	}
    	// Add another virtual server
    	vs3 := &utilipvs.VirtualServer{
    		Address:  netutils.ParseIPSloppy("10::40"),
    		Port:     uint16(7777),
    		Protocol: string("SCTP"),
    	}
    	err = fake.AddVirtualServer(vs3)
    	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)
  2. pkg/proxy/ipvs/util/ipvs.go

    type Interface interface {
    	// Flush clears all virtual servers in system. return occurred error immediately.
    	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
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/util/testing/fake.go

    }
    
    func toRealServerKey(rs *utilipvs.RealServer) *RealServerKey {
    	return &RealServerKey{
    		Address: rs.Address,
    		Port:    rs.Port,
    	}
    }
    
    // AddVirtualServer is a fake implementation, it simply adds the VirtualServer into the cache store.
    func (f *FakeIPVS) AddVirtualServer(serv *utilipvs.VirtualServer) error {
    	if serv == nil {
    		return fmt.Errorf("failed to add virtual server, error: virtual server can't be nil")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 7K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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