Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 99 for lobster (0.18 sec)

  1. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go

    	fts feature.Features,
    ) framework.Plugin {
    	pvLister := informerFactory.Core().V1().PersistentVolumes().Lister()
    	pvcLister := informerFactory.Core().V1().PersistentVolumeClaims().Lister()
    	csiNodesLister := informerFactory.Storage().V1().CSINodes().Lister()
    	scLister := informerFactory.Storage().V1().StorageClasses().Lister()
    
    	return newNonCSILimits(ctx, filterName, csiNodesLister, scLister, pvLister, pvcLister, fts)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	informerFactory := handle.SharedInformerFactory()
    	pvLister := informerFactory.Core().V1().PersistentVolumes().Lister()
    	pvcLister := informerFactory.Core().V1().PersistentVolumeClaims().Lister()
    	csiNodesLister := informerFactory.Storage().V1().CSINodes().Lister()
    	scLister := informerFactory.Storage().V1().StorageClasses().Lister()
    	csiTranslator := csitrans.New()
    
    	return &CSILimits{
    		csiNodeLister:        csiNodesLister,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. plugin/pkg/admission/runtimeclass/admission_test.go

    	}{
    		{
    			name:         "runtimeClass found by lister",
    			expectError:  false,
    			runtimeClass: newRuntimeClassForTest(true, rc, true, nil),
    		},
    		{
    			name:         "runtimeClass found by client",
    			expectError:  false,
    			runtimeClass: newRuntimeClassForTest(true, nil, true, rc),
    		},
    		{
    			name:         "runtimeClass not found by lister nor client",
    			expectError:  true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 17 01:30:14 UTC 2022
    - 17.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/rest/rest.go

    type GroupVersionAcceptor interface {
    	AcceptsGroupVersion(gv schema.GroupVersion) bool
    }
    
    // Lister is an object that can retrieve resources that match the provided field and label criteria.
    type Lister interface {
    	// NewList returns an empty object that can be used with the List call.
    	// This object must be a pointer type for use with Codec.DecodeInto([]byte, runtime.Object)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 18.6K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/pv_controller_base.go

    		},
    	)
    	controller.claimLister = p.ClaimInformer.Lister()
    	controller.claimListerSynced = p.ClaimInformer.Informer().HasSynced
    
    	controller.classLister = p.ClassInformer.Lister()
    	controller.classListerSynced = p.ClassInformer.Informer().HasSynced
    	controller.podLister = p.PodInformer.Lister()
    	controller.podIndexer = p.PodInformer.Informer().GetIndexer()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  6. pkg/registry/flowcontrol/rest/storage_flowcontrol.go

    			p.InformerFactory.Flowcontrol().V1().FlowSchemas().Informer().HasSynced,
    		},
    		fsLister:  p.InformerFactory.Flowcontrol().V1().FlowSchemas().Lister(),
    		plcLister: p.InformerFactory.Flowcontrol().V1().PriorityLevelConfigurations().Lister(),
    	}
    	return PostStartHookName, bce.ensureAPFBootstrapConfiguration, nil
    }
    
    type bootstrapConfigurationEnsurer struct {
    	informersSynced []cache.InformerSynced
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  7. pkg/scheduler/testing/framework/fake_listers.go

    // we just return everything.
    func (nodes NodeInfoLister) HavePodsWithAffinityList() ([]*framework.NodeInfo, error) {
    	return nodes, nil
    }
    
    // HavePodsWithRequiredAntiAffinityList is supposed to list nodes with at least one pod with
    // required anti-affinity. For the fake lister we just return everything.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 20 10:14:08 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  8. pkg/kubeapiserver/options/authentication.go

    		nodeLister = versionedInformer.Core().V1().Nodes().Lister()
    	}
    	authenticatorConfig.ServiceAccountTokenGetter = serviceaccountcontroller.NewGetterFromClient(
    		extclient,
    		versionedInformer.Core().V1().Secrets().Lister(),
    		versionedInformer.Core().V1().ServiceAccounts().Lister(),
    		versionedInformer.Core().V1().Pods().Lister(),
    		nodeLister,
    	)
    	authenticatorConfig.SecretsWriter = extclient.CoreV1()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  9. pkg/controller/endpointslice/endpointslice_controller.go

    	})
    	c.serviceLister = serviceInformer.Lister()
    	c.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addPod,
    		UpdateFunc: c.updatePod,
    		DeleteFunc: c.deletePod,
    	})
    	c.podLister = podInformer.Lister()
    	c.podsSynced = podInformer.Informer().HasSynced
    
    	c.nodeLister = nodeInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  10. src/cmd/vendor/github.com/google/pprof/internal/report/report.go

    		for _, n := range ns {
    			locStr := ""
    			// Skip loc information if it hasn't changed from previous instruction.
    			if n.function != function || n.file != file || n.line != line {
    				function, file, line = n.function, n.file, n.line
    				if n.function != "" {
    					locStr = n.function + " "
    				}
    				if n.file != "" {
    					locStr += n.file
    					if n.line != 0 {
    						locStr += fmt.Sprintf(":%d", n.line)
    					}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 37.5K bytes
    - Viewed (0)
Back to top