- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 124 for Proxier (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
cmd/kubemark/app/hollow_node.go
fs.BoolVar(&c.UseRealProxier, "use-real-proxier", true, "Has no effect.") _ = fs.MarkDeprecated("use-real-proxier", "This flag is deprecated and will be removed in a future release.") fs.DurationVar(&c.ProxierSyncPeriod, "proxier-sync-period", 30*time.Second, "Has no effect.") _ = fs.MarkDeprecated("proxier-sync-period", "This flag is deprecated and will be removed in a future release.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
cmd/kube-proxy/app/server_other.go
// platformSetup is called after setting up the ProxyServer, but before creating the // Proxier. It should fill in any platform-specific fields and perform other // platform-specific setup. func (s *ProxyServer) platformSetup(ctx context.Context) error { return unsupportedError } // platformCheckSupported is called immediately before creating the Proxier, to check // what IP families are supported (and whether the configuration is usable at all).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
// Should return 200 "OK" after processing update for both IPv4 and IPv6 proxiers. hs.Updated(v1.IPv4Protocol) hs.Updated(v1.IPv6Protocol) fakeClock.Step(5 * time.Second) testHTTPHandler(hsTest, http.StatusOK, t) // If IPv6 proxier is late for an update but IPv4 proxier is not then updating IPv4 proxier should have no effect. hs.QueuedUpdate(v1.IPv6Protocol) fakeClock.Step(25 * time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/proxy/ipvs/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 makeEndpointSliceMap(proxier *Proxier, allEpSlices ...*discovery.EndpointSlice) { for i := range allEpSlices { proxier.OnEndpointSliceAdd(allEpSlices[i]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0)