- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 333 for Indexer (1.78 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller.go
}, UpdateFunc: func(oldObj, newObj interface{}) { adc.podUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { adc.podDelete(logger, obj) }, }) // This custom indexer will index pods by its PVC keys. Then we don't need // to iterate all pods every time to find pods which reference given PVC. if err := common.AddPodPVCIndexerIfNotPresent(adc.podIndexer); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.indexer; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.function.Consumer; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
for _, cn := range n { if cn.Name == name { return &cn, nil } } return nil, fmt.Errorf("csiNode %q not found", name) } // List lists all CSINodes in the indexer. func (n CSINodeLister) List(selector labels.Selector) (ret []*storagev1.CSINode, err error) { return nil, fmt.Errorf("not implemented") } func getFakeCSINodeLister(csiNode *storagev1.CSINode) CSINodeLister {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
break } logger.V(5).Info("Getting Node object failed, waiting", "err", err) select { case <-ctx.Done(): return case <-time.After(time.Second): } } // We could use an indexer on driver name, but that seems overkill. informer := resourceinformers.NewFilteredResourceSliceInformer(c.kubeClient, resyncPeriod, nil, func(options *metav1.ListOptions) { options.FieldSelector = "nodeName=" + node.Name })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pilot/pkg/model/virtualservice.go
// root virtualservices with delegate var rootVses []config.Config // 1. classify virtualservices for _, vs := range vServices { rule := vs.Spec.(*networking.VirtualService) // it is delegate, add it to the indexer cache along with the exportTo for the delegate if len(rule.Hosts) == 0 { delegatesMap[vs.NamespacedName()] = vs var exportToSet sets.Set[visibility.Instance] if len(rule.ExportTo) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 11:17:03 UTC 2024 - 17.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
if err != nil { return nil, err } return objIndexFunc(seo) } } func storeElementIndexers(indexers *cache.Indexers) cache.Indexers { if indexers == nil { return cache.Indexers{} } ret := cache.Indexers{} for indexName, indexFunc := range *indexers { ret[indexName] = storeElementIndexFunc(indexFunc) } return ret } // watchCache implements a Store interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
podsLister corelisters.PodLister claimsLister corelisters.PersistentVolumeClaimLister setsLister appslisters.StatefulSetLister podsIndexer cache.Indexer claimsIndexer cache.Indexer setsIndexer cache.Indexer revisionsIndexer cache.Indexer createPodTracker requestTracker updatePodTracker requestTracker deletePodTracker requestTracker }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
} // Test the ActualStateOfWorld contains all the node volumes nodes, err := adc.nodeLister.List(labels.Everything()) if err != nil { t.Fatalf("Failed to list nodes in indexer. Expected: <no error> Actual: %v", err) } for _, node := range nodes { nodeName := types.NodeName(node.Name) inUseVolumes := sets.New(node.Status.VolumesInUse...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) nodeInformer := informerFactory.Core().V1().Nodes() indexer := nodeInformer.Informer().GetIndexer() for _, nodeName := range nodeNames { indexer.Add(&v1.Node{ObjectMeta: metav1.ObjectMeta{Name: nodeName}}) } esInformer := informerFactory.Discovery().V1().EndpointSlices() esIndexer := esInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
controller.podListerSynced = p.PodInformer.Informer().HasSynced controller.NodeLister = p.NodeInformer.Lister() controller.NodeListerSynced = p.NodeInformer.Informer().HasSynced // This custom indexer will index pods by its PVC keys. Then we don't need // to iterate all pods every time to find pods which reference given PVC. if err := common.AddPodPVCIndexerIfNotPresent(controller.podIndexer); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0)