Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for sync_bg (0.52 sec)

  1. build/release-images.sh

        CMD_TARGETS="${CMD_TARGETS} ${KUBE_CONFORMANCE_IMAGE_TARGETS[*]}"
    fi
    # include extra WHAT if specified so you can build docker images + binaries
    # in one call with a single pass of syncing to the container + generating code
    if [[ -n "${KUBE_EXTRA_WHAT:-}" ]]; then
        CMD_TARGETS="${CMD_TARGETS} ${KUBE_EXTRA_WHAT}"
    fi
    
    kube::build::verify_prereqs
    kube::build::build_image
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 16:43:08 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. pkg/controller/podautoscaler/config/types.go

    	// Larger number = more responsive HPA processing, but more CPU (and network) load.
    	ConcurrentHorizontalPodAutoscalerSyncs int32
    	// horizontalPodAutoscalerSyncPeriod is the period for syncing the number of
    	// pods in horizontal pod autoscaler.
    	HorizontalPodAutoscalerSyncPeriod metav1.Duration
    	// HorizontalPodAutoscalerDowncaleStabilizationWindow is a period for which autoscaler will look
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 19 09:49:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. pkg/controller/certificates/certificate_controller.go

    			cc.enqueueCertificateRequest(obj)
    		},
    	})
    	cc.csrLister = csrInformer.Lister()
    	cc.csrsSynced = csrInformer.Informer().HasSynced
    	return cc
    }
    
    // Run the main goroutine responsible for watching and syncing jobs.
    func (cc *CertificateController) Run(ctx context.Context, workers int) {
    	defer utilruntime.HandleCrash()
    	defer cc.queue.ShutDown()
    
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. pkg/controller/certificates/rootcacertpublisher/publisher.go

    		utilruntime.HandleError(fmt.Errorf("syncing %q failed: %v", key, err))
    		c.queue.AddRateLimited(key)
    		return true
    	}
    
    	c.queue.Forget(key)
    	return true
    }
    
    func (c *Publisher) syncNamespace(ctx context.Context, ns string) (err error) {
    	startTime := time.Now()
    	defer func() {
    		recordMetrics(startTime, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. cmd/kube-controller-manager/app/options/hpacontroller.go

    	fs.DurationVar(&o.HorizontalPodAutoscalerSyncPeriod.Duration, "horizontal-pod-autoscaler-sync-period", o.HorizontalPodAutoscalerSyncPeriod.Duration, "The period for syncing the number of pods in horizontal pod autoscaler.")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 19 09:49:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. pkg/controller/storageversionmigrator/storageversionmigrator.go

    	if quit {
    		return false
    	}
    	defer svmc.queue.Done(key)
    
    	err := svmc.sync(ctx, key)
    	if err == nil {
    		svmc.queue.Forget(key)
    		return true
    	}
    
    	klog.FromContext(ctx).V(2).Info("Error syncing SVM resource, retrying", "svm", key, "err", err)
    	svmc.queue.AddRateLimited(key)
    
    	return true
    }
    
    func (svmc *SVMController) sync(ctx context.Context, key string) error {
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  7. cmd/kube-controller-manager/app/options/persistentvolumebindercontroller.go

    	if o == nil {
    		return
    	}
    
    	fs.DurationVar(&o.PVClaimBinderSyncPeriod.Duration, "pvclaimbinder-sync-period", o.PVClaimBinderSyncPeriod.Duration, "The period for syncing persistent volumes and persistent volume claims")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. pkg/controller/volume/persistentvolume/config/types.go

    )
    
    // PersistentVolumeBinderControllerConfiguration contains elements describing
    // PersistentVolumeBinderController.
    type PersistentVolumeBinderControllerConfiguration struct {
    	// pvClaimBinderSyncPeriod is the period for syncing persistent volumes
    	// and persistent volume claims.
    	PVClaimBinderSyncPeriod metav1.Duration
    	// volumeConfiguration holds configuration for volume related features.
    	VolumeConfiguration VolumeConfiguration
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java

     * It does not deal as well with large jumps back in time.
     * <p>
     * When the system wall clock jumps back in time, this clock will effectively slow down until it is back in sync.
     * All syncing timestamps will be the same as the previously issued timestamp.
     * The rate by which this clock slows, and therefore the time it takes to resync,
     * is determined by how frequently the clock is read.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 20:20:17 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. pkg/controlplane/controller/legacytokentracking/controller.go

    	key, quit := c.queue.Get()
    	if quit {
    		return false
    	}
    	defer c.queue.Done(key)
    
    	if err := c.syncConfigMap(); err != nil {
    		utilruntime.HandleError(fmt.Errorf("while syncing ConfigMap %q, err: %w", key, err))
    		c.queue.AddRateLimited(key)
    		return true
    	}
    	c.queue.Forget(key)
    	return true
    }
    
    func (c *Controller) syncConfigMap() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top