Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 308 for Proxier (0.16 sec)

  1. pkg/proxy/nftables/proxier.go

    		proxier.nodeLabels[k] = v
    	}
    	proxier.mu.Unlock()
    	proxier.logger.V(4).Info("Updated proxier node labels", "labels", node.Labels)
    
    	proxier.Sync()
    }
    
    // OnNodeUpdate is called whenever modification of an existing
    // node object is observed.
    func (proxier *Proxier) OnNodeUpdate(oldNode, node *v1.Node) {
    	if node.Name != proxier.hostname {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. pkg/proxy/winkernel/proxier.go

    func (proxier *Proxier) SyncLoop() {
    	// Update healthz timestamp at beginning in case Sync() never succeeds.
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.Updated(proxier.ipFamily)
    	}
    	// synthesize "last change queued" time as the informers are syncing.
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Loop(wait.NeverStop)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier.go

    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.QueuedUpdate(proxier.ipFamily)
    	}
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Run()
    }
    
    // SyncLoop runs periodic work.  This is expected to run as a goroutine or as the main loop of the app.  It does not return.
    func (proxier *Proxier) SyncLoop() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier.go

    	}
    }
    
    // This assumes proxier.mu is held
    func (proxier *Proxier) probability(n int) string {
    	if n >= len(proxier.precomputedProbabilities) {
    		proxier.precomputeProbabilities(n)
    	}
    	return proxier.precomputedProbabilities[n]
    }
    
    // Sync is called to synchronize the proxier state to iptables as soon as possible.
    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  5. pkg/proxy/metaproxier/meta_proxier.go

    // proxy rules.
    func (proxier *metaProxier) Sync() {
    	proxier.ipv4Proxier.Sync()
    	proxier.ipv6Proxier.Sync()
    }
    
    // SyncLoop runs periodic work.  This is expected to run as a
    // goroutine or as the main loop of the app.  It does not return.
    func (proxier *metaProxier) SyncLoop() {
    	go proxier.ipv6Proxier.SyncLoop() // Use go-routine here!
    	proxier.ipv4Proxier.SyncLoop()    // never returns
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/proxier_test.go

    }
    
    func makeServiceMap(proxier *Proxier, allServices ...*v1.Service) {
    	for i := range allServices {
    		proxier.OnServiceAdd(allServices[i])
    	}
    
    	proxier.mu.Lock()
    	defer proxier.mu.Unlock()
    	proxier.servicesSynced = true
    }
    func deleteServices(proxier *Proxier, allServices ...*v1.Service) {
    	for i := range allServices {
    		proxier.OnServiceDelete(allServices[i])
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  7. cmd/kube-proxy/app/server_windows.go

    	}
    
    	var proxier proxy.Provider
    	var err error
    
    	if dualStackMode {
    		proxier, err = winkernel.NewDualStackProxier(
    			config.IPTables.SyncPeriod.Duration,
    			config.IPTables.MinSyncPeriod.Duration,
    			s.Hostname,
    			s.NodeIPs,
    			s.Recorder,
    			s.HealthzServer,
    			config.HealthzBindAddress,
    			config.Winkernel,
    		)
    	} else {
    		proxier, err = winkernel.NewProxier(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. cmd/kube-proxy/app/server_linux.go

    				initOnly,
    			)
    		}
    		if err != nil {
    			return nil, fmt.Errorf("unable to create proxier: %v", err)
    		}
    	} else if config.Mode == proxyconfigapi.ProxyModeNFTables {
    		logger.Info("Using nftables Proxier")
    
    		if dualStack {
    			// TODO this has side effects that should only happen when Run() is invoked.
    			proxier, err = nftables.NewDualStackProxier(
    				ctx,
    				config.NFTables.SyncPeriod.Duration,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    		}
    		cfg.TLS = tlsConfig
    	}
    	if cfg.Proxier == nil {
    		cfg.Proxier = utilnet.NewProxierWithNoProxyCIDR(http.ProxyFromEnvironment)
    	}
    	return &SpdyRoundTripper{
    		tlsConfig:        cfg.TLS,
    		proxier:          cfg.Proxier,
    		pingPeriod:       cfg.PingPeriod,
    		upgradeTransport: cfg.UpgradeTransport,
    	}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/README.md

    ```
    Using ipvs Proxier.
    ```
    
    While there is no IPVS proxy rules or the following logs occurs indicate that the kube-proxy fails to use IPVS mode:
    ```
    Can't use ipvs proxier, trying iptables proxier
    Using iptables Proxier.
    ```
    See the following section for more details on debugging.
    
    ## Debug
    
    ### Check IPVS proxy rules
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 20 02:32:29 UTC 2021
    - 18.8K bytes
    - Viewed (0)
Back to top