- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Informer (0.21 sec)
-
pkg/controller/endpointslice/endpointslice_controller.go
} serviceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.onServiceUpdate, UpdateFunc: func(old, cur interface{}) { c.onServiceUpdate(cur) }, DeleteFunc: c.onServiceDelete, }) c.serviceLister = serviceInformer.Lister() c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
}, { name: "node added to informer after quarantine", delay: 2 * quarantineTime, addedInformerNodes: []*v1.Node{testutil.NewNode("node")}, pods: []*v1.Pod{ makePod("a", "node", v1.PodFailed), }, itemsInQueue: 1, }, { // It shouldn't happen that client will be lagging behind informer. // This test case is more a sanity check.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
podLister corelisters.PodLister // podListerSynced returns true if the pod shared informer has synced at least once podListerSynced cache.InformerSynced // setLister is able to list/get stateful sets from a shared informer's store setLister appslisters.StatefulSetLister // setListerSynced returns true if the stateful set shared informer has synced at least once setListerSynced cache.InformerSynced
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/scheduler/scheduler.go
if accessor, err := meta.Accessor(obj); err == nil { if accessor.GetManagedFields() != nil { accessor.SetManagedFields(nil) } } return obj, nil } informer.SetTransform(trim) return informer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
// Package crdclient provides an implementation of the config store and cache // using Kubernetes Custom Resources and the informer framework from Kubernetes // // This code relies heavily on code generation for performance reasons; to implement the // Istio store interface, we need to take dynamic inputs. Using the dynamic informers results in poor // performance, as the cache will store unstructured objects which need to be marshaled on each Get/List call.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/volume/plugins.go
SetKubeletError(err error) // GetInformerFactory returns the informer factory for CSIDriverLister GetInformerFactory() informers.SharedInformerFactory // CSIDriverLister returns the informer lister for the CSIDriver API Object CSIDriverLister() storagelistersv1.CSIDriverLister // CSIDriverSynced returns the informer synced for the CSIDriver API Object CSIDriversSynced() cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return nil, fmt.Errorf("failed to find pod %v", ns) } if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } // Gets a point-in-time snapshot of all pods that are CURRENTLY ambient enabled // (as per control plane annotation)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
namespaces.AddEventHandler(clienttest.TrackerHandler(tracker)) // This is not great! But seems the best we can do. // For namespaces specifically we have an interesting race. // We will have 2+ informer handlers: the filter itself, and N controllers. // The ordering of handlers if random. If the filter receives the event first, it could suppress re-sending the namespace event,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
} func (vm *volumeManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() if vm.kubeClient != nil { // start informer for CSIDriver go vm.volumePluginMgr.Run(stopCh) } go vm.desiredStateOfWorldPopulator.Run(sourcesReady, stopCh) klog.V(2).InfoS("The desired_state_of_world populator starts")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
logger.Error(err, "Error scheduling pod; retrying", "pod", klog.KObj(pod)) } // Check if the Pod exists in informer cache. podLister := fwk.SharedInformerFactory().Core().V1().Pods().Lister() cachedPod, e := podLister.Pods(pod.Namespace).Get(pod.Name) if e != nil { logger.Info("Pod doesn't exist in informer cache", "pod", klog.KObj(pod), "err", e)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0)