- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 99 for lobster (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)