- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 100 for sync_bg (0.25 sec)
-
pkg/proxy/config/config.go
func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) { c.eventHandlers = append(c.eventHandlers, handler) } // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller") if !cache.WaitForNamedCacheSync("endpoint slice config", stopCh, c.listerSynced) { return
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
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) -
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) -
pkg/controller/servicecidrs/servicecidrs_controller.go
startTime := time.Now() defer func() { logger.V(4).Info("Finished syncing ServiceCIDR)", "ServiceCIDR", key, "elapsed", time.Since(startTime)) }() // TODO(aojea) verify if this present a performance problem // restore the radix tree from the current state err := c.syncCIDRs() if err != nil { return err } logger.V(4).Info("syncing ServiceCIDR", "ServiceCIDR", key) cidr, err := c.serviceCIDRLister.Get(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
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) -
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) -
build/common.sh
# container over the local network. function kube::build::sync_to_container() { kube::log::status "Syncing sources to container" kube::build::start_rsyncd_container # rsync filters are a bit confusing. Here we are syncing everything except # output only directories and things that are not necessary like the git # directory and generated files. The '- /' filter prevents rsync
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 26.5K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
logger.Error(err, "Failed to split meta namespace cache key", "cacheKey", key) return err } startTime := time.Now() logger.V(4).Info("Started syncing deployment", "deployment", klog.KRef(namespace, name), "startTime", startTime) defer func() { logger.V(4).Info("Finished syncing deployment", "deployment", klog.KRef(namespace, name), "duration", time.Since(startTime)) }() deployment, err := dc.dLister.Deployments(namespace).Get(name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
err := jm.podBackoffStore.removeBackoffRecord(key) if err != nil { // re-syncing here as the record has to be removed for finished/deleted jobs return fmt.Errorf("error removing backoff record %w", err) } return nil } return err } // Skip syncing of the job it is managed by another controller. // We cannot rely solely on skipping of queueing such jobs for synchronization,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
configCluster := "syncing" if kube.AllSynced(c.configClusterSyncers) { configCluster = "synced" } out := []cluster.DebugInfo{{ ID: c.configClusterID, SyncStatus: configCluster, }} // Append each cluster derived from secrets for secretName, clusters := range c.cs.All() { for clusterID, c := range clusters { syncStatus := "syncing" if c.Closed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0)