- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,244 for syncFn (0.17 sec)
-
pkg/kubelet/runonce.go
return fmt.Errorf("error syncing pod %q: %v", format.Pod(pod), err) } if retry >= runOnceMaxRetries { return fmt.Errorf("timeout error: pod %q containers not running after %d retries", format.Pod(pod), runOnceMaxRetries) } // TODO(proppy): health checking would be better than waiting + checking the state at the next iteration. klog.InfoS("Pod's containers synced, waiting", "pod", klog.KObj(pod), "duration", delay)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
qm.monitorLock.RLock() defer qm.monitorLock.RUnlock() if len(qm.monitors) == 0 { logger.V(4).Info("quota monitor not synced: no monitors") return false } for resource, monitor := range qm.monitors { if !monitor.controller.HasSynced() { logger.V(4).Info("quota monitor not synced", "resource", resource) return false } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/replicasetcontroller.go
func (o *ReplicaSetControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentRSSyncs, "concurrent-replicaset-syncs", o.ConcurrentRSSyncs, "The number of replica sets that are allowed to sync concurrently. Larger number = more responsive replica management, but more CPU (and network) load") } // ApplyTo fills up ReplicaSetController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/endpointcontroller.go
func (o *EndpointControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentEndpointSyncs, "concurrent-endpoint-syncs", o.ConcurrentEndpointSyncs, "The number of endpoint syncing operations that will be done concurrently. Larger number = faster endpoint updating, but more CPU (and network) load")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 24 09:36:53 UTC 2019 - 2.2K bytes - Viewed (0) -
architecture/networking/controllers.md
A queue is used to give a few properties: * Ability to serially process updates received from a variety of different sources. This avoids need for other synchronization mechanisms like mutexes. * Correctness at startup; with the sequencing above, items are only processed once all informers are synced. This means queries will not return stale data at startup.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/volume/csi/testing/testing.go
factory.Start(wait.NeverStop) syncedTypes := factory.WaitForCacheSync(wait.NeverStop) if len(syncedTypes) != 1 { t.Fatalf("informers are not synced") } for ty, ok := range syncedTypes { if !ok { t.Fatalf("failed to sync: %#v", ty) } } host := volumetest.NewFakeVolumeHostWithCSINodeName(t, tmpDir, client, csi.ProbeVolumePlugins(), "fakeNode", csiDriverLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/controller/podautoscaler/config/types.go
type HPAControllerConfiguration struct { // ConcurrentHorizontalPodAutoscalerSyncs is the number of HPA objects that are allowed to sync concurrently. // 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 19 09:49:23 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/dsl/org.gradle.api.tasks.Sync.xml
Laura Kassovic <******@****.***> 1701107622 -0800
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 795 bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
if err := cc.syncFunc(ctx, cKey); err != nil { cc.queue.AddRateLimited(cKey) if _, ignorable := err.(ignorableError); !ignorable { utilruntime.HandleError(fmt.Errorf("Sync %v failed with : %v", cKey, err)) } else { klog.FromContext(ctx).V(4).Info("Sync certificate request failed", "csr", cKey, "err", err) } return true } cc.queue.Forget(cKey) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kube/krt/internal.go
// registerHandlerAsBatched is a helper to register the provided handler as a batched handler. This allows collections to // only implement RegisterBatch. func registerHandlerAsBatched[T any](c internalCollection[T], f func(o Event[T])) Syncer { return c.RegisterBatch(func(events []Event[T], initialSync bool) { for _, o := range events { f(o) } }, true) } // castEvent converts an Event[I] to Event[O].
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 5.6K bytes - Viewed (0)