Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 99 for lobster (0.11 sec)

  1. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    ) *framework.Status {
    	if len(nodes) == 0 {
    		// No nodes to score.
    		return framework.NewStatus(framework.Skip)
    	}
    
    	if pl.sharedLister == nil {
    		return framework.NewStatus(framework.Error, "empty shared lister in InterPodAffinity PreScore")
    	}
    
    	affinity := pod.Spec.Affinity
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  2. pkg/controller/disruption/disruption.go

    			dc.removeDB(logger, obj)
    		},
    	})
    	dc.pdbLister = pdbInformer.Lister()
    	dc.pdbListerSynced = pdbInformer.Informer().HasSynced
    
    	dc.rcLister = rcInformer.Lister()
    	dc.rcListerSynced = rcInformer.Informer().HasSynced
    
    	dc.rsLister = rsInformer.Lister()
    	dc.rsListerSynced = rsInformer.Informer().HasSynced
    
    	dc.dLister = dInformer.Lister()
    	dc.dListerSynced = dInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/DefaultMavenArtifactRepository.java

            InstantiatingAction<ComponentMetadataListerDetails> lister = createComponentMetadataVersionLister(injector, isolatableFactory);
            return new MavenResolver(getDescriptor(), rootUri, transport, locallyAvailableResourceFinder, artifactFileStore, metadataSources, MavenMetadataArtifactProvider.INSTANCE, mavenMetadataLoader, supplier, lister, injector, checksumService);
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 18 21:30:55 UTC 2023
    - 21.7K bytes
    - Viewed (0)
  4. pkg/volume/csi/csi_attacher.go

    	attachment, err := c.plugin.volumeAttachmentLister.Get(attachID)
    	if err != nil && !apierrors.IsNotFound(err) {
    		return "", errors.New(log("failed to get volume attachment from lister: %v", err))
    	}
    
    	if attachment == nil {
    		var vaSrc storage.VolumeAttachmentSource
    		if spec.InlineVolumeSpecForCSIMigration {
    			// inline PV scenario - use PV spec to populate VA source.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 03 07:38:14 UTC 2023
    - 25.9K bytes
    - Viewed (0)
  5. pkg/controller/resourcequota/resource_quota_controller_test.go

    	return func(gvr schema.GroupVersionResource) (cache.GenericLister, error) {
    		lister, found := listersForResource[gvr]
    		if !found {
    			return nil, fmt.Errorf("no lister found for resource")
    		}
    		return lister, nil
    	}
    }
    
    func newGenericLister(groupResource schema.GroupResource, items []runtime.Object) cache.GenericLister {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 16:29:33 UTC 2023
    - 42.6K bytes
    - Viewed (0)
  6. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    		},
    		DeleteFunc: c.onEndpointSliceDelete,
    	})
    
    	c.endpointSliceLister = endpointSliceInformer.Lister()
    	c.endpointSlicesSynced = endpointSliceInformer.Informer().HasSynced
    	c.endpointSliceTracker = endpointsliceutil.NewEndpointSliceTracker()
    
    	c.serviceLister = serviceInformer.Lister()
    	c.servicesSynced = serviceInformer.Informer().HasSynced
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    type NamingConditionController struct {
    	crdClient client.CustomResourceDefinitionsGetter
    
    	crdLister listers.CustomResourceDefinitionLister
    	crdSynced cache.InformerSynced
    	// crdMutationCache backs our lister and keeps track of committed updates to avoid racy
    	// write/lookup cycles.  It's got 100 slots by default, so it unlikely to overrun
    	// TODO to revisit this if naming conflicts are found to occur in the wild
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. platforms/core-configuration/model-core/src/integTest/groovy/org/gradle/model/managed/ManagedModelGroovyScalarConfigurationIntegrationTest.groovy

    @UnsupportedWithConfigurationCache(because = "software model")
    class ManagedModelGroovyScalarConfigurationIntegrationTest extends AbstractIntegrationSpec {
    
        private static final String CLASSES = '''
            enum Thing {
                TOASTER,
                NOT_A_TOASTER
            }
    
            @Managed
            interface Props {
                Thing getTheThing()
                void setTheThing(Thing t)
    
                boolean isBool1()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Sep 28 09:51:04 UTC 2023
    - 19.7K bytes
    - Viewed (0)
  9. pkg/controller/podgc/gc_controller.go

    	gcc := &PodGCController{
    		kubeClient:             kubeClient,
    		terminatedPodThreshold: terminatedPodThreshold,
    		podLister:              podInformer.Lister(),
    		podListerSynced:        podInformer.Informer().HasSynced,
    		nodeLister:             nodeInformer.Lister(),
    		nodeListerSynced:       nodeInformer.Informer().HasSynced,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go

    					t.Errorf("Unexpected Filter status (-want, +got): %s", diff)
    				}
    			}
    		})
    	}
    }
    
    func TestAccessModeConflicts(t *testing.T) {
    	// Required for querying lister for PVCs in the same namespace.
    	podWithOnePVC := st.MakePod().Name("pod-with-one-pvc").Namespace(metav1.NamespaceDefault).PVC("claim-with-rwop-1").Node("node-1").Obj()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 17.3K bytes
    - Viewed (0)
Back to top