Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for workerCh (0.44 sec)

  1. pkg/kubelet/kubelet_pods.go

    	// These two conditions could be alleviated by checkpointing kubelet.
    
    	// Stop the workers for terminated pods not in the config source
    	klog.V(3).InfoS("Clean up pod workers for terminated pods")
    	workingPods := kl.podWorkers.SyncKnownPods(allPods)
    
    	// Reconcile: At this point the pod workers have been pruned to the set of
    	// desired pods. Pods that must be restarted due to UID reuse, or leftover
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	if firstSeenTimeStr, ok := pod.Annotations[kubetypes.ConfigFirstSeenAnnotationKey]; ok {
    		firstSeenTime = kubetypes.ConvertToTimestamp(firstSeenTimeStr).Get()
    	}
    
    	// Record pod worker start latency if being created
    	// TODO: make pod workers record their own latencies
    	if updateType == kubetypes.SyncPodCreate {
    		if !firstSeenTime.IsZero() {
    			// This is the first time we are syncing the pod. Record the latency
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_waypoint.go

    		UpgradeType: ConnectUpgradeType,
    	}}
    	h.Http2ProtocolOptions = &core.Http2ProtocolOptions{
    		AllowConnect: true,
    		// TODO(https://github.com/istio/istio/issues/43443)
    		// All streams are bound to the same worker. Therefore, we need to limit for better fairness.
    		MaxConcurrentStreams: &wrappers.UInt32Value{Value: 100},
    		// well behaved clients should close connections.
    		// not all clients are well-behaved. This will prune
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  4. docs/en/docs/release-notes.md

    * 🌐 Update German translation for `docs/de/docs/features.md`. PR [#10284](https://github.com/tiangolo/fastapi/pull/10284) by [@nilslindemann](https://github.com/nilslindemann).
    * 🌐 Add German translation for `docs/de/docs/deployment/server-workers.md`. PR [#10747](https://github.com/tiangolo/fastapi/pull/10747) by [@nilslindemann](https://github.com/nilslindemann).
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Jun 14 15:07:37 UTC 2024
    - 395.4K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_test.go

    			ID:        "12345678",
    			Name:      "bar",
    			Namespace: "new",
    			Containers: []*kubecontainer.Container{
    				{Name: "foo"},
    			},
    		}},
    	}
    
    	// Let the pod worker sets the status to fail after this sync.
    	kubelet.HandlePodUpdates(pods)
    	status, found := kubelet.statusManager.GetPodStatus(pods[0].UID)
    	assert.True(t, found, "expected to found status for pod %q", pods[0].UID)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top