- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for resyncPeriod (0.21 sec)
-
pkg/proxy/config/config.go
logger klog.Logger } // NewEndpointSliceConfig creates a new EndpointSliceConfig. func NewEndpointSliceConfig(ctx context.Context, endpointSliceInformer discoveryv1informers.EndpointSliceInformer, resyncPeriod time.Duration) *EndpointSliceConfig { result := &EndpointSliceConfig{ listerSynced: endpointSliceInformer.Informer().HasSynced, logger: klog.FromContext(ctx), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "resourcequota_priority"}, ), resyncPeriod: options.ResyncPeriod, registry: options.Registry, } // set the synchronization handler rq.syncHandler = rq.syncResourceQuotaFromKey logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
workqueue.DefaultTypedControllerRateLimiter[*event](), workqueue.TypedRateLimitingQueueConfig[*event]{Name: "resource_quota_controller_resource_changes"}, ), resyncPeriod: resyncPeriod, replenishmentFunc: replenishmentFunc, registry: registry, updateFilter: updateFilter, } } // monitor runs a Controller with a local stop channel. type monitor struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
// NewInformerFactory creates a SharedInformerFactory and initializes a scheduler specific // in-place podInformer. func NewInformerFactory(cs clientset.Interface, resyncPeriod time.Duration) informers.SharedInformerFactory { informerFactory := informers.NewSharedInformerFactory(cs, resyncPeriod) informerFactory.InformerFor(&v1.Pod{}, newPodInformer) return informerFactory }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
cliflag.SetUsageAndHelpFunc(cmd, namedFlagSets, cols) return cmd } // ResyncPeriod returns a function which generates a duration each time it is // invoked; this is so that multiple controllers don't get into lock-step and all // hammer the apiserver with list requests simultaneously. func ResyncPeriod(c *config.CompletedConfig) func() time.Duration { return func() time.Duration { factor := rand.Float64() + 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
pkg/config/schema/kubeclient/common.go
return c.Dynamic().Resource(g).Namespace(opts.Namespace).Watch(context.Background(), options) }, }, &unstructured.Unstructured{}, cache.SharedIndexInformerOptions{ ResyncPeriod: 0, Indexers: cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, ObjectDescription: g.String(), }, ) setupInformer(opts, inf) return inf }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
ctx context.Context, kubeClient clientset.Interface, metadataClient metadata.Interface, discoverResourcesFn func() ([]*metav1.APIResourceList, error), namespaceInformer coreinformers.NamespaceInformer, resyncPeriod time.Duration, finalizerToken v1.FinalizerName) *NamespaceController { // create the controller so we can inject the enqueue function namespaceController := &NamespaceController{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
if err != nil { utilruntime.HandleError(err) } // Add request processing HPA to queue with resyncPeriod delay. // Requests are always added to queue with resyncPeriod delay. If there's already request // for the HPA in the queue then a new request is always dropped. Requests spend resyncPeriod // in queue so HPAs are processed every resyncPeriod. // Request is added here just in case last resync didn't insert request into the queue. This
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
var csiDriverLister storagelisters.CSIDriverLister var csiDriversSynced cache.InformerSynced const resyncPeriod = 0 // Don't initialize if kubeClient is nil if kubelet.kubeClient != nil { informerFactory = informers.NewSharedInformerFactory(kubelet.kubeClient, resyncPeriod) csiDriverInformer := informerFactory.Storage().V1().CSIDrivers() csiDriverLister = csiDriverInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
"k8s.io/client-go/util/workqueue" "k8s.io/klog/v2" drapb "k8s.io/kubelet/pkg/apis/dra/v1alpha3" "k8s.io/utils/ptr" ) const ( // resyncPeriod for informer // TODO (https://github.com/kubernetes/kubernetes/issues/123688): disable? resyncPeriod = time.Duration(10 * time.Minute) retryPeriod = 5 * time.Second maxRetryPeriod = 180 * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0)