Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newServiceHealthServer (0.37 sec)

  1. pkg/proxy/healthcheck/service_health.go

    		nodeIPs:       nodeIPs,
    	}
    }
    
    // NewServiceHealthServer allocates a new service healthcheck server manager
    func NewServiceHealthServer(hostname string, recorder events.EventRecorder, nodePortAddresses *proxyutil.NodePortAddresses, healthzServer proxierHealthChecker) ServiceHealthServer {
    	return newServiceHealthServer(hostname, recorder, stdNetListener{}, stdHTTPServerFactory{}, nodePortAddresses, healthzServer)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 30 09:25:48 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  2. pkg/proxy/healthcheck/healthcheck_test.go

    	httpFactory := newFakeHTTPServerFactory()
    	nodePortAddresses := proxyutil.NewNodePortAddresses(v1.IPv4Protocol, []string{})
    	proxyChecker := &fakeProxierHealthChecker{true}
    
    	hcsi := newServiceHealthServer("hostname", nil, listener, httpFactory, nodePortAddresses, proxyChecker)
    	hcs := hcsi.(*server)
    	if len(hcs.services) != 0 {
    		t.Errorf("expected 0 services, got %d", len(hcs.services))
    	}
    
    	// sync nothing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier.go

    		nodeIP = netutils.ParseIPSloppy("127.0.0.1")
    	}
    
    	// windows listens to all node addresses
    	nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nil)
    	serviceHealthServer := healthcheck.NewServiceHealthServer(hostname, recorder, nodePortAddresses, healthzServer)
    
    	var healthzPort int
    	if len(healthzBindAddress) > 0 {
    		_, port, _ := net.SplitHostPort(healthzBindAddress)
    		healthzPort, _ = strconv.Atoi(port)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    	logger.V(2).Info("Using nftables mark for masquerade", "mark", masqueradeMark)
    
    	nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nodePortAddressStrings)
    
    	serviceHealthServer := healthcheck.NewServiceHealthServer(hostname, recorder, nodePortAddresses, healthzServer)
    
    	var nftablesFamily knftables.Family
    	if ipFamily == v1.IPv4Protocol {
    		nftablesFamily = knftables.IPv4Family
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/iptables/proxier.go

    	masqueradeValue := 1 << uint(masqueradeBit)
    	masqueradeMark := fmt.Sprintf("%#08x", masqueradeValue)
    	logger.V(2).Info("Using iptables mark for masquerade", "mark", masqueradeMark)
    
    	serviceHealthServer := healthcheck.NewServiceHealthServer(hostname, recorder, nodePortAddresses, healthzServer)
    	nfacctRunner, err := nfacct.New()
    	if err != nil {
    		logger.Error(err, "Failed to create nfacct runner")
    	}
    
    	proxier := &Proxier{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier.go

    		scheduler = defaultScheduler
    	}
    
    	nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nodePortAddressStrings)
    
    	serviceHealthServer := healthcheck.NewServiceHealthServer(hostname, recorder, nodePortAddresses, healthzServer)
    
    	// excludeCIDRs has been validated before, here we just parse it to IPNet list
    	parsedExcludeCIDRs, _ := netutils.ParseCIDRs(excludeCIDRs)
    
    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