Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 99 for lobster (0.17 sec)

  1. cmd/kube-scheduler/app/server.go

    	configz.InstallHandler(pathRecorderMux)
    	pathRecorderMux.Handle("/metrics", legacyregistry.HandlerWithReset())
    
    	resourceMetricsHandler := resources.Handler(informers.Core().V1().Pods().Lister())
    	pathRecorderMux.HandleFunc("/metrics/resources", func(w http.ResponseWriter, req *http.Request) {
    		if !isLeader() {
    			return
    		}
    		resourceMetricsHandler.ServeHTTP(w, req)
    	})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  2. istioctl/pkg/tag/generate.go

    	// TODO(Monkeyanator) once we stop using Helm templating remove this.
    	ManifestsPath string
    	// Generate determines whether we should just generate the webhooks without applying. This
    	// applying is not done here, but we are looser with checks when doing generate.
    	Generate bool
    	// Overwrite removes analysis checks around existing webhooks.
    	Overwrite bool
    	// AutoInjectNamespaces controls, if the sidecars should be injected into all namespaces by default.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 17:43:49 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    func New(_ context.Context, _ runtime.Object, handle framework.Handle, fts feature.Features) (framework.Plugin, error) {
    	informerFactory := handle.SharedInformerFactory()
    	pvcLister := informerFactory.Core().V1().PersistentVolumeClaims().Lister()
    	sharedLister := handle.SnapshotSharedLister()
    
    	return &VolumeRestrictions{
    		pvcLister:    pvcLister,
    		sharedLister: sharedLister,
    	}, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  4. pkg/volume/csi/csi_block_test.go

    	}
    
    	// after the driver is created, create the plugin. newTestPlugin waits for the informer to sync,
    	// such that csiMapper.SetUpDevice below sees the VolumeAttachment object in the lister.
    
    	plug, tmpDir := newTestPlugin(t, fakeClient)
    	defer os.RemoveAll(tmpDir)
    
    	csiMapper, _, _, err := prepareBlockMapperTest(plug, "test-pv", t)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  5. plugin/pkg/admission/noderestriction/admission.go

    }
    
    // SetExternalKubeInformerFactory registers an informer factory into Plugin
    func (p *Plugin) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) {
    	p.podsGetter = f.Core().V1().Pods().Lister()
    	p.nodesGetter = f.Core().V1().Nodes().Lister()
    }
    
    // ValidateInitialization validates the Plugin was initialized properly
    func (p *Plugin) ValidateInitialization() error {
    	if p.nodeIdentifier == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  6. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/OutputScrapingExecutionResult.java

    import java.util.List;
    import java.util.Optional;
    import java.util.Set;
    import java.util.TreeSet;
    import java.util.regex.Pattern;
    
    public class OutputScrapingExecutionResult implements ExecutionResult {
        // This monster is to find lines in our logs that look like stack traces
        // We want to match lines that contain just packages and classes:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 19K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_node_status.go

    	if timeout {
    		klog.ErrorS(nil, "Node not becoming ready in time after startup")
    		return true
    	}
    
    	originalNode, err := kl.GetNode()
    	if err != nil {
    		klog.ErrorS(err, "Error getting the current node from lister")
    		return false
    	}
    
    	readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady)
    	if readyIdx == -1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  8. pkg/registry/flowcontrol/ensurer/strategy.go

    	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
    }
    
    // cache is the needed fragment of the typed generated access ("lister") to an informer's local cache
    type cache[ObjectType configurationObject] interface {
    	List(labels.Selector) ([]ObjectType, error)
    	Get(name string) (ObjectType, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 14K bytes
    - Viewed (0)
  9. maven-core/plugin-manager.txt

    - I could make an annotation that marked another class as its plugin discoverer, I could just add it to
      the component descriptor and when it's loaded we can add the discoverer, that would be simpler. I could
      also do this with the lister as well
    i'l
    // 1 the metadata -> model plugin/mojo descriptor
    // 2 tools for doing the mapping
    // 3 the component model -> interfaces for the plugin
    
    // The plugin manager should load up a directory structure of plugins.
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Mon Jul 18 22:45:13 UTC 2022
    - 12.9K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    			})
    		}
    		scorer = buildScorerFunction(shape)
    	}
    	return &VolumeBinding{
    		Binder:    binder,
    		PVCLister: pvcInformer.Lister(),
    		scorer:    scorer,
    		fts:       fts,
    	}, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
Back to top