Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for DestroySet (0.24 sec)

  1. cni/pkg/ipset/ipset.go

    func NewIPSet(name string, deps NetlinkIpsetDeps) (IPSet, error) {
    	set := IPSet{
    		Name: name,
    		Deps: deps,
    	}
    	err := deps.ipsetIPPortCreate(name)
    	return set, err
    }
    
    func (m *IPSet) DestroySet() error {
    	return m.Deps.destroySet(m.Name)
    }
    
    func (m *IPSet) AddIP(ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	return m.Deps.addIP(m.Name, ip, ipProto, comment, replace)
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2K bytes
    - Viewed (0)
  2. cni/pkg/ipset/nldeps_mock.go

    func FakeNLDeps() *MockedIpsetDeps {
    	return &MockedIpsetDeps{}
    }
    
    func (m *MockedIpsetDeps) ipsetIPPortCreate(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) destroySet(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_unspecified.go

    	return &realDeps{}
    }
    
    type realDeps struct{}
    
    func (m *realDeps) ipsetIPPortCreate(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. cni/pkg/ipset/nldeps_linux.go

    	if ipsetErr, ok := err.(nl.IPSetError); ok && ipsetErr == nl.IPSET_ERR_EXIST {
    		return nil
    	}
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    func (s *NetServer) Stop() {
    	log.Debug("removing host iptables rules")
    	s.iptablesConfigurator.DeleteHostRules()
    
    	log.Debug("destroying host ipset")
    	s.hostsideProbeIPSet.Flush()
    	if err := s.hostsideProbeIPSet.DestroySet(); err != nil {
    		log.Warnf("could not destroy host ipset on shutdown")
    	}
    	log.Debug("stopping ztunnel server")
    	s.ztunnelServer.Close()
    }
    
    func (s *NetServer) rescanPod(pod *corev1.Pod) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.1K bytes
    - Viewed (1)
Back to top