- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for sync_bg (0.13 sec)
-
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) -
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) -
pkg/proxy/metrics/metrics.go
"k8s.io/kubernetes/pkg/proxy/util/nfacct" ) const kubeProxySubsystem = "kubeproxy" var ( // SyncProxyRulesLatency is the latency of one round of kube-proxy syncing proxy // rules. (With the iptables proxy, this includes both full and partial syncs.) SyncProxyRulesLatency = metrics.NewHistogram( &metrics.HistogramOpts{ Subsystem: kubeProxySubsystem,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.7K bytes - Viewed (0) -
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) -
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) -
pkg/kube/multicluster/secretcontroller_test.go
c.Run(stop) // before sync assert.EventuallyEqual(t, c.controller.ListRemoteClusters, []cluster.DebugInfo{ {ID: "config", SyncStatus: "syncing"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "syncing"}, {ID: "c1", SecretName: "istio-system/s1", SyncStatus: "syncing"}, }) assert.EventuallyEqual(t, func() int { return len(c.component.All()) }, 3) // Sync all but one for _, c := range c.component.All() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
} if loggerV := logger.V(6); loggerV.Enabled() { // Dump entire resource information. loggerV.Info("Syncing existing driver node resource slices with driver resources", "slices", klog.KObjSlice(slices), "resources", driverResources) } else { logger.V(5).Info("Syncing existing driver node resource slices with driver resources", "slices", klog.KObjSlice(slices), "numResources", len(driverResources)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
// StatefulSetController controls statefulsets. type StatefulSetController struct { // client interface kubeClient clientset.Interface // control returns an interface capable of syncing a stateful set. // Abstracted out for testing. control StatefulSetControlInterface // podControl is used for patching pods. podControl controller.PodControlInterface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
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)