Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for QueuedUpdate (0.11 sec)

  1. pkg/proxy/healthcheck/healthcheck_test.go

    	fakeClock.Step(5 * time.Second)
    	testHTTPHandler(hsTest, http.StatusOK, t)
    
    	// Should return 503 "ServiceUnavailable" if both IPv4 and IPv6 proxiers exceed max update-processing time.
    	hs.QueuedUpdate(v1.IPv4Protocol)
    	hs.QueuedUpdate(v1.IPv6Protocol)
    	fakeClock.Step(25 * time.Second)
    	testHTTPHandler(hsTest, http.StatusServiceUnavailable, t)
    
    	// Should return 200 "OK" after processing update for both IPv4 and IPv6 proxiers.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  2. pkg/proxy/healthcheck/proxier_health.go

    //  3. sync node status, for reporting unhealthy /healthz response
    //     if the node is marked for deletion by autoscaler.
    //  4. get proxy health by verifying that the delay between QueuedUpdate()
    //     calls and Updated() calls exceeded healthTimeout or not.
    type ProxierHealthServer struct {
    	listener    listener
    	httpFactory httpServerFactory
    	clock       clock.Clock
    
    	addr          string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 10:41:18 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier.go

    			}
    		}
    	}
    }
    
    // Sync is called to synchronize the proxier state to hns as soon as possible.
    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.QueuedUpdate(proxier.ipFamily)
    	}
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Run()
    }
    
    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

    	return encounteredError
    }
    
    // Sync is called to synchronize the proxier state to nftables as soon as possible.
    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.QueuedUpdate(proxier.ipFamily)
    	}
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Run()
    }
    
    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

    }
    
    // Sync is called to synchronize the proxier state to iptables as soon as possible.
    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.QueuedUpdate(proxier.ipFamily)
    	}
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Run()
    }
    
    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

    	return encounteredError
    }
    
    // Sync is called to synchronize the proxier state to iptables and ipvs as soon as possible.
    func (proxier *Proxier) Sync() {
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.QueuedUpdate(proxier.ipFamily)
    	}
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Run()
    }
    
    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