- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for resyncPeriod (0.14 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) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
informerType := reflect.TypeOf(obj) informer, exists := f.informers[informerType] if exists { return informer } resyncPeriod, exists := f.customResync[informerType] if !exists { resyncPeriod = f.defaultResync } informer = newFunc(f.client, resyncPeriod) informer.SetTransform(f.transform) f.informers[informerType] = informer return informer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
informerType := reflect.TypeOf(obj) informer, exists := f.informers[informerType] if exists { return informer } resyncPeriod, exists := f.customResync[informerType] if !exists { resyncPeriod = f.defaultResync } informer = newFunc(f.client, resyncPeriod) informer.SetTransform(f.transform) f.informers[informerType] = informer return informer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K 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)