- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 94 for lobster (0.27 sec)
-
pkg/kubelet/volume_host.go
if kubelet.kubeClient != nil { informerFactory = informers.NewSharedInformerFactory(kubelet.kubeClient, resyncPeriod) csiDriverInformer := informerFactory.Storage().V1().CSIDrivers() csiDriverLister = csiDriverInformer.Lister() csiDriversSynced = csiDriverInformer.Informer().HasSynced } else { klog.InfoS("KubeClient is nil. Skip initialization of CSIDriverLister") } kvh := &kubeletVolumeHost{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/value.go
initValueSet sync.Once valueSet map[ref.Val]struct{} } // Add concatenates two lists together to produce a new CEL list value. func (lv *ListValue) Add(other ref.Val) ref.Val { oArr, isArr := other.(traits.Lister) if !isArr { return types.MaybeNoSuchOverloadErr(other) } szRight := len(lv.Entries) szLeft := int(oArr.Size().(types.Int)) sz := szRight + szLeft combo := make([]ref.Val, sz)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 10 22:05:55 UTC 2022 - 20.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go
p += "/" } newQuery[subpathKey] = []string{p} query = newQuery } return scope.ParameterCodec.DecodeParameters(query, scope.Kind.GroupVersion(), into) } func ListResource(r rest.Lister, rw rest.Watcher, scope *RequestScope, forceWatch bool, minRequestTimeout time.Duration) http.HandlerFunc { return func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() // For performance tracking purposes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
func TestSyncDeploymentDeletionRace(t *testing.T) { _, ctx := ktesting.NewTestContext(t) f := newFixture(t) d := newDeployment("foo", 1, nil, nil, nil, map[string]string{"foo": "bar"}) d2 := *d // Lister (cache) says NOT deleted. f.dLister = append(f.dLister, d) // Bare client says it IS deleted. This should be presumed more up-to-date. now := metav1.Now() d2.DeletionTimestamp = &now
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
AddFunc: func(obj interface{}) { tc.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { tc.updateJob(logger, oldObj, newObj) }, }) tc.jLister = jobInformer.Lister() tc.jListerSynced = jobInformer.Informer().HasSynced tc.clock = clock.RealClock{} return tc } // Run starts the workers to clean up Jobs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin.go
return nil, err } pl := &InterPodAffinity{ parallelizer: h.Parallelizer(), args: args, sharedLister: h.SnapshotSharedLister(), nsLister: h.SharedInformerFactory().Core().V1().Namespaces().Lister(), } return pl, nil } func getArgs(obj runtime.Object) (config.InterPodAffinityArgs, error) { ptr, ok := obj.(*config.InterPodAffinityArgs) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
itemsInQueue int deletedPodNames sets.Set[string] patchedPodNames sets.Set[string] enablePodDisruptionConditions bool }{ { name: "nodes present in lister", initialInformerNodes: []*v1.Node{ testutil.NewNode("existing1"), testutil.NewNode("existing2"), }, delay: 2 * quarantineTime, pods: []*v1.Pod{ makePod("a", "existing1", v1.PodRunning),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
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 (1)