- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 99 for lobster (0.17 sec)
-
pkg/controller/replication/conversion.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_dispatcher.go
paramKind.String()) } // Set up cluster-scoped, or namespaced access to the params // "default" if not provided, and paramKind is namespaced paramStore = paramInformer.Lister() if paramScope.Name() == meta.RESTScopeNameNamespace { paramsNamespace := namespace if len(paramRef.Namespace) > 0 { paramsNamespace = paramRef.Namespace } else if len(paramsNamespace) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/value_test.go
ov.Append(testValue(t, 2, "second")) ov.Append(testValue(t, 3, "third")) llv := NewListValue() llv.Append(testValue(t, 4, lv)) lov := NewListValue() lov.Append(testValue(t, 5, ov)) var v traits.Lister = llv.Add(lov).(traits.Lister) if v.Size() != types.Int(2) { t.Errorf("got list size %d, wanted 2", v.Size()) } complex, err := v.ConvertToNative(reflect.TypeOf([][]string{})) complexList := complex.([][]string) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 10 22:05:55 UTC 2022 - 10.4K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
if isIPv6 { family = api.IPv6Protocol } c := &MetaAllocator{ client: client, serviceCIDRLister: serviceCIDRInformer.Lister(), serviceCIDRSynced: serviceCIDRInformer.Informer().HasSynced, ipAddressLister: ipAddressInformer.Lister(), ipAddressSynced: ipAddressInformer.Informer().HasSynced, ipAddressInformer: ipAddressInformer, queue: workqueue.NewTypedRateLimitingQueueWithConfig(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
return nil, err } pl := DefaultPreemption{ fh: fh, fts: fts, args: *args, podLister: fh.SharedInformerFactory().Core().V1().Pods().Lister(), pdbLister: getPDBLister(fh.SharedInformerFactory()), } return &pl, nil } // PostFilter invoked at the postFilter extension point.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
jobControl: realJobControl{KubeClient: kubeClient}, cronJobControl: &realCJControl{KubeClient: kubeClient}, jobLister: jobInformer.Lister(), cronJobLister: cronJobsInformer.Lister(), jobListerSynced: jobInformer.Informer().HasSynced, cronJobListerSynced: cronJobsInformer.Informer().HasSynced, now: time.Now, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
} type expandController struct { // kubeClient is the kube API client used by volumehost to communicate with // the API server. kubeClient clientset.Interface // pvcLister is the shared PVC lister used to fetch and store PVC // objects from the API server. It is shared with other controllers and // therefore the PVC objects in its store should be treated as immutable. pvcLister corelisters.PersistentVolumeClaimLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
dc.deletePod(logger, obj) }, }) dc.syncHandler = dc.syncDeployment dc.enqueueDeployment = dc.enqueue dc.dLister = dInformer.Lister() dc.rsLister = rsInformer.Lister() dc.podLister = podInformer.Lister() dc.dListerSynced = dInformer.Informer().HasSynced dc.rsListerSynced = rsInformer.Informer().HasSynced dc.podListerSynced = podInformer.Informer().HasSynced return dc, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
factory := informers.NewSharedInformerFactory(client, CsiResyncPeriod) csiDriverInformer := factory.Storage().V1().CSIDrivers() csiDriverLister := csiDriverInformer.Lister() volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments() volumeAttachmentLister := volumeAttachmentInformer.Lister() factory.Start(wait.NeverStop) syncedTypes := factory.WaitForCacheSync(wait.NeverStop) if len(syncedTypes) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/resolver/ResourceVersionLister.java
throw ResourceExceptions.failure(versionListPattern.getUri(), String.format("Could not list versions using %s.", pattern), e); } } // lists all the values a revision token listed by a given url lister private List<String> listRevisionToken(ExternalResourceName versionListPattern, BuildableModuleVersionListingResolveResult result, Map<ResourcePattern, ExternalResourceName> versionListPatterns) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 10.3K bytes - Viewed (0)