- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for lobster (0.13 sec)
-
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
Operation* op) { RegionResourceHoister hoister(op); if (failed(hoister.Analyze())) return failure(); // If there are no resource region captures, then nothing to do. if (!hoister.NeedsLifting()) return success(); // Start the transformation. For each region, replace the resource read with // the value read before the op. hoister.GenerateHoistedReads(); hoister.ReplaceResourceLoads(/*read_only=*/false);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) nsu := statusupdater.NewNodeStatusUpdater( fakeKubeClient, informerFactory.Core().V1().Nodes().Lister(), asw) nodeLister := informerFactory.Core().V1().Nodes().Lister() reconciler := NewReconciler( reconcilerLoopPeriod, maxWaitForUnmountDuration, syncLoopPeriod, false, false, dsw, asw, ad, nsu, nodeLister, fakeRecorder) // Act
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/history/controller_history_test.go
informerFactory.WaitForCacheSync(stop) for i := range test.revisions { informer.Informer().GetIndexer().Add(test.revisions[i]) } history := NewHistory(client, informer.Lister()) revisions, err := history.ListControllerRevisions(test.parent, test.selector) if err != nil { t.Errorf("%s: %s", test.name, err) } got := make(map[string]bool) for i := range revisions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
} // what verbs are supported by the storage, used to know what verbs we support per path creater, isCreater := storage.(rest.Creater) namedCreater, isNamedCreater := storage.(rest.NamedCreater) lister, isLister := storage.(rest.Lister) getter, isGetter := storage.(rest.Getter) getterWithOptions, isGetterWithOptions := storage.(rest.GetterWithOptions) gracefulDeleter, isGracefulDeleter := storage.(rest.GracefulDeleter)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
classLister: fh.SharedInformerFactory().Resource().V1alpha2().ResourceClasses().Lister(), podSchedulingContextLister: fh.SharedInformerFactory().Resource().V1alpha2().PodSchedulingContexts().Lister(), claimParametersLister: fh.SharedInformerFactory().Resource().V1alpha2().ResourceClaimParameters().Lister(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
for _, obj := range objs { pod, ok := obj.(*v1.Pod) if !ok { continue } pods = append(pods, pod) } return pods, nil } nc.podLister = podInformer.Lister() nc.nodeLister = nodeInformer.Lister() if !utilfeature.DefaultFeatureGate.Enabled(features.SeparateTaintEvictionController) { logger.Info("Running TaintEvictionController as part of NodeLifecyleController")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
dsc.updateDaemonset(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { dsc.deleteDaemonset(logger, obj) }, }) dsc.dsLister = daemonSetInformer.Lister() dsc.dsStoreSynced = daemonSetInformer.Informer().HasSynced historyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dsc.addHistory(logger, obj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
t.setObjectMeta(foo1, t.namer(1)) foo2 := obj.DeepCopyObject() t.setObjectMeta(foo2, t.namer(2)) existing := assignFn([]runtime.Object{foo1, foo2}) listObj, err := t.storage.(rest.Lister).List(ctx, nil) if err != nil { t.Errorf("unexpected error: %v", err) } items, err := listToItems(listObj) if err != nil { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
common/scripts/metallb-native.yaml
--- apiVersion: rbac.authorization.k8s.io/v1 kind: RoleBinding metadata: labels: app: metallb name: pod-lister namespace: metallb-system roleRef: apiGroup: rbac.authorization.k8s.io kind: Role name: pod-lister subjects: - kind: ServiceAccount name: speaker namespace: metallb-system --- apiVersion: rbac.authorization.k8s.io/v1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 23:56:31 UTC 2024 - 63.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func WithPodMaxBackoffDuration(duration time.Duration) Option { return func(o *priorityQueueOptions) { o.podMaxBackoffDuration = duration } } // WithPodLister sets pod lister for PriorityQueue. func WithPodLister(pl listersv1.PodLister) Option { return func(o *priorityQueueOptions) { o.podLister = pl } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)