- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,924 for proxier (0.13 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) -
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) -
pkg/proxy/winkernel/proxier_test.go
svcFunc(svc) return svc } func deleteEndpointSlices(proxier *Proxier, allEndpointSlices ...*discovery.EndpointSlice) { for i := range allEndpointSlices { proxier.OnEndpointSliceDelete(allEndpointSlices[i]) } proxier.mu.Lock() defer proxier.mu.Unlock() proxier.endpointSlicesSynced = true } func populateEndpointSlices(proxier *Proxier, allEndpointSlices ...*discovery.EndpointSlice) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/kube-proxy/app/server_windows.go
return } // createProxier creates the proxy.Provider func (s *ProxyServer) createProxier(ctx context.Context, config *proxyconfigapi.KubeProxyConfiguration, dualStackMode, initOnly bool) (proxy.Provider, error) { if initOnly { return nil, fmt.Errorf("--init-only is not implemented on Windows") } var proxier proxy.Provider var err error if dualStackMode { proxier, err = winkernel.NewDualStackProxier(
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) -
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) -
pkg/proxy/healthcheck/proxier_health.go
hs.lastUpdatedMap[ipFamily] = hs.clock.Now() } // QueuedUpdate should be called when the proxier receives a Service or Endpoints event // from API Server containing information that requires updating service rules. It // indicates that the proxier for the given IP family has received changes but has not // yet pushed them to its backend. If the proxier does not call Updated within the // healthTimeout time then it will be considered unhealthy.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0)