- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 144 for sync_bg (0.21 sec)
-
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) -
pkg/controller/endpointslicemirroring/config/types.go
// EndpointSliceMirroringController. type EndpointSliceMirroringControllerConfiguration struct { // mirroringConcurrentServiceEndpointSyncs is the number of service endpoint // syncing operations that will be done concurrently. Larger number = faster // endpoint slice updating, but more CPU (and network) load. MirroringConcurrentServiceEndpointSyncs int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 06 19:43:33 UTC 2020 - 1.7K bytes - Viewed (0) -
pkg/controller/endpoint/config/types.go
) // EndpointControllerConfiguration contains elements describing EndpointController. type EndpointControllerConfiguration struct { // concurrentEndpointSyncs is the number of endpoint syncing operations // that will be done concurrently. Larger number = faster endpoint updating, // but more CPU (and network) load. ConcurrentEndpointSyncs int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 24 09:36:53 UTC 2019 - 1.4K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
"istio.io/istio/pkg/monitoring" ) var ( clusterLabel = monitoring.CreateLabel("cluster") errorMetric = monitoring.NewSum( "controller_sync_errors_total", "Total number of errorMetric syncing controllers.", ) mu sync.RWMutex handlers = map[cluster.ID]cache.WatchErrorHandler{} ) // ErrorHandlerForCluster fetches or creates an ErrorHandler that emits a metric
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0) -
pkg/kubelet/prober/testing/fake_manager.go
func (FakeManager) StopLivenessAndStartup(_ *v1.Pod) {} // CleanupPods simulates cleaning up Pods. func (FakeManager) CleanupPods(_ map[types.UID]sets.Empty) {} // Start simulates start syncing the probe status func (FakeManager) Start() {} // UpdatePodStatus simulates updating the Pod Status. func (FakeManager) UpdatePodStatus(_ *v1.Pod, podStatus *v1.PodStatus) { for i := range podStatus.ContainerStatuses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 1.4K 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/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/endpointslice/config/types.go
) // EndpointSliceControllerConfiguration contains elements describing // EndpointSliceController. type EndpointSliceControllerConfiguration struct { // concurrentServiceEndpointSyncs is the number of service endpoint syncing // operations that will be done concurrently. Larger number = faster // endpoint slice updating, but more CPU (and network) load. ConcurrentServiceEndpointSyncs int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 03 07:16:42 UTC 2020 - 1.7K 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) -
cmd/kube-controller-manager/app/options/namespacecontroller.go
func (o *NamespaceControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.DurationVar(&o.NamespaceSyncPeriod.Duration, "namespace-sync-period", o.NamespaceSyncPeriod.Duration, "The period for syncing namespace life-cycle updates")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.9K bytes - Viewed (0)