- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 99 for lobster (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)