Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for LoggerWithValues (0.17 sec)

  1. pkg/scheduler/framework/runtime/framework.go

    		// Run Score method for each node in parallel.
    		f.Parallelizer().Until(ctx, len(nodes), func(index int) {
    			nodeName := nodes[index].Node().Name
    			logger := logger
    			if verboseLogs {
    				logger = klog.LoggerWithValues(logger, "node", klog.ObjectRef{Name: nodeName})
    			}
    			for _, pl := range plugins {
    				ctx := ctx
    				if verboseLogs {
    					logger := klog.LoggerWithName(logger, pl.Name())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  2. pkg/proxy/nftables/proxier.go

    	hostname string,
    	nodeIP net.IP,
    	recorder events.EventRecorder,
    	healthzServer *healthcheck.ProxierHealthServer,
    	nodePortAddressStrings []string,
    	initOnly bool,
    ) (*Proxier, error) {
    	logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily)
    
    	if initOnly {
    		logger.Info("System initialized and --init-only specified")
    		return nil, nil
    	}
    
    	// Generate the masquerade mark to use for SNAT rules.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier.go

    	hostname string,
    	nodeIP net.IP,
    	recorder events.EventRecorder,
    	healthzServer *healthcheck.ProxierHealthServer,
    	nodePortAddressStrings []string,
    	initOnly bool,
    ) (*Proxier, error) {
    	logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily)
    	nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nodePortAddressStrings)
    
    	if !nodePortAddresses.ContainsIPv4Loopback() {
    		localhostNodePorts = false
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    	nodeIP net.IP,
    	recorder events.EventRecorder,
    	healthzServer *healthcheck.ProxierHealthServer,
    	scheduler string,
    	nodePortAddressStrings []string,
    	initOnly bool,
    ) (*Proxier, error) {
    	logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily)
    	// Set the conntrack sysctl we need for
    	if err := proxyutil.EnsureSysctl(sysctl, sysctlVSConnTrack, 1); err != nil {
    		return nil, err
    	}
    
    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