Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 144 for sync_bg (0.14 sec)

  1. pkg/kubelet/nodestatus/setters.go

    ) Setter {
    	return func(ctx context.Context, node *v1.Node) error {
    		// Make sure to only update node status after reconciler starts syncing up states
    		if syncedFunc() {
    			node.Status.VolumesInUse = volumesInUseFunc()
    		}
    		return nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  2. pkg/registry/core/pod/strategy.go

    					deprecationWarning = true
    				}
    
    				if deprecationWarning {
    					// Note: annotation deprecation warning must be added here rather than the
    					// typical WarningsOnCreate path to emit the warning before syncing the
    					// annotations & fields.
    					fldPath := field.NewPath("metadata", "annotations").Key(key)
    					warning.AddWarning(ctx, "", fmt.Sprintf(`%s: deprecated since v1.30; use the "appArmorProfile" field instead`, fldPath))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/controller.go

    func (s *Controller) ResyncEDS() {
    	s.mutex.RLock()
    	allInstances := s.serviceInstances.getAll()
    	s.mutex.RUnlock()
    	s.edsUpdate(allInstances)
    	// HACK to workaround Service syncing after WorkloadEntry: https://github.com/istio/istio/issues/45114
    	s.workloadInstances.ForEach(func(wi *model.WorkloadInstance) {
    		if wi.Kind == model.WorkloadEntryKind {
    			s.NotifyWorkloadInstanceHandlers(wi, model.EventAdd)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    				// UID is updated, which causes pod config to deliver DELETE -> ADD while the old pod is still shutting
    				// down and the pod worker to ignore the ADD. The HandlePodCleanups method then is responsible for syncing
    				// that pod to the pod worker so that it restarts.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  5. pkg/controller/podautoscaler/horizontal.go

    		tolerance,
    		cpuInitializationPeriod,
    		delayOfInitialReadinessStatus,
    	)
    	hpaController.replicaCalc = replicaCalc
    
    	monitor.Register()
    
    	return hpaController
    }
    
    // Run begins watching and syncing.
    func (a *HorizontalController) Run(ctx context.Context, workers int) {
    	defer utilruntime.HandleCrash()
    	defer a.queue.ShutDown()
    
    	logger := klog.FromContext(ctx)
    	logger.Info("Starting HPA controller")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/binder_test.go

    			expectedEvents:  []string{"Warning VolumeMismatch"},
    			errors:          noerrors,
    			test:            testSyncClaim,
    		},
    
    		// [Unit test set 3] Syncing bound claim
    		{
    			// syncClaim with claim  bound and its claim.Spec.VolumeName is
    			// removed. Check it's marked as Lost.
    			name:            "3-1 - bound claim with missing VolumeName",
    			initialVolumes:  novolumes,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 65.8K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    func (m *kubeGenericRuntimeManager) computePodActions(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus) podActions {
    	klog.V(5).InfoS("Syncing Pod", "pod", klog.KObj(pod))
    
    	createPodSandbox, attempt, sandboxID := runtimeutil.PodSandboxChanged(pod, podStatus)
    	changes := podActions{
    		KillPod:           createPodSandbox,
    		CreateSandbox:     createPodSandbox,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    		10*time.Second)
    
    	// Wait for informers cache sync
    	informerFactory.Start(ctx.Done())
    	for v, synced := range informerFactory.WaitForCacheSync(ctx.Done()) {
    		if !synced {
    			logger.Error(nil, "Error syncing informer", "informer", v)
    			os.Exit(1)
    		}
    	}
    
    	// Add storageclasses
    	waitMode := storagev1.VolumeBindingWaitForFirstConsumer
    	immediateMode := storagev1.VolumeBindingImmediate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  9. platforms/documentation/docs/src/docs/userguide/optimizing-performance/configuration_cache.adoc

    `gradle.properties` is usually checked in to source control.
    If you don't want to enable the configuration cache for your whole team yet you can also enable the configuration cache from your IDE only as explained below.
    
    Note that syncing a build from an IDE doesn't benefit from the configuration cache, only running tasks does.
    
    [[config_cache:ide:intellij]]
    === IntelliJ based IDEs
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 29 16:24:12 UTC 2024
    - 71.1K bytes
    - Viewed (0)
  10. prow/config/calico.yaml

                          Enabled by default, set to nil to disable.
                        properties:
                          hostEndpoint:
                            description: HostEndpoint controls syncing nodes to host endpoints.
                              Disabled by default, set to nil to disable.
                            properties:
                              autoCreate:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 246.5K bytes
    - Viewed (0)
Back to top