Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for DeleteVirtualServer (0.28 sec)

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

    	// 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.
    	DeleteVirtualServer(*VirtualServer) error
    	// Given a partial virtual server, GetVirtualServer will return the specified virtual server information in the system.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/util/testing/fake.go

    	}
    	key := toServiceKey(serv)
    	f.Services[key] = serv
    	return nil
    }
    
    // DeleteVirtualServer is a fake implementation, it simply deletes the VirtualServer from the cache store.
    func (f *FakeIPVS) DeleteVirtualServer(serv *utilipvs.VirtualServer) error {
    	if serv == nil {
    		return fmt.Errorf("failed to delete 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)
  3. pkg/proxy/ipvs/util/testing/fake_test.go

    	if err != nil {
    		t.Errorf("Fail to list virtual servers, error: %v", err)
    	}
    	if len(list) != 3 {
    		t.Errorf("Expect 2 virtual servers, got: %d", len(list))
    	}
    	// Delete a virtual server
    	err = fake.DeleteVirtualServer(vs1)
    	if err != nil {
    		t.Errorf("Fail to delete virtual server: %v, error: %v", vs1, err)
    	}
    	// Check the deleted virtual server no longer exists
    	got, _ := fake.GetVirtualServer(vs1)
    	if got != 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)
  4. pkg/proxy/ipvs/util/ipvs_linux.go

    	}
    	runner.mu.Lock()
    	defer runner.mu.Unlock()
    	return runner.ipvsHandle.UpdateService(svc)
    }
    
    // DeleteVirtualServer is part of ipvs.Interface.
    func (runner *runner) DeleteVirtualServer(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.go

    		logger.Info("Dummy VS not created", "scheduler", scheduler)
    		return fmt.Errorf("Ipvs not supported") // This is a BUG work-around
    	}
    	logger.V(5).Info("Dummy VS created", "vs", vs)
    
    	if err := ipvs.DeleteVirtualServer(&vs); err != nil {
    		logger.Error(err, "Could not delete dummy VS")
    		return err
    	}
    
    	return nil
    }
    
    // CleanupIptablesLeftovers removes all iptables rules and chains created by the Proxier
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier_test.go

    		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
    }
    func (f *fakeIpvs) GetVirtualServer(*utilipvs.VirtualServer) (*utilipvs.VirtualServer, error) {
    	return nil, 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