- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 201 for newFoo (0.35 sec)
-
pkg/apis/batch/v1beta1/defaults_test.go
Suspend: newBool(true), SuccessfulJobsHistoryLimit: utilpointer.Int32(5), FailedJobsHistoryLimit: utilpointer.Int32(5), }, }, expected: &batchv1beta1.CronJob{ Spec: batchv1beta1.CronJobSpec{ ConcurrencyPolicy: batchv1beta1.ForbidConcurrent, Suspend: newBool(true), SuccessfulJobsHistoryLimit: utilpointer.Int32(5),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:14:37 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
func TestOrderedByPriorityProcess(t *testing.T) { pod1 := newPod("low-priority-high-usage", lowPriority, nil, nil) pod2 := newPod("low-priority-low-usage", lowPriority, nil, nil) pod3 := newPod("high-priority-high-usage", highPriority, nil, nil) pod4 := newPod("high-priority-low-usage", highPriority, nil, nil) stats := map[*v1.Pod]statsapi.PodStats{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/rewrite_tpu_embedding_ops.cc
auto operands = llvm::to_vector<4>(op->getOperands()); operands.push_back(operand); auto new_op = builder->create<OpT>(op->getLoc(), op->getResultTypes(), operands, attr.getAttrs()); op->replaceAllUsesWith(new_op.getOperation()->getResults()); op->erase(); return new_op; } // Returns success if the function has at most one op of the template type and
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 22:55:42 UTC 2024 - 4.5K bytes - Viewed (0) -
plugin/pkg/admission/namespace/exists/admission_test.go
Name: ns, ResourceVersion: fmt.Sprintf("%d", i), }, }) } return true, namespaceList, nil }) return mockClient } // newPod returns a new pod for the specified namespace func newPod(namespace string) api.Pod { return api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace}, Spec: api.PodSpec{ Volumes: []api.Volume{{Name: "vol"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go
&example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "newpod"}}, &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "oldpod"}}, ), // name gets overwritten from converted attributes, type gets set explicitly VersionedObject: &examplev1.Pod{TypeMeta: metav1.TypeMeta{APIVersion: "example.apiserver.k8s.io/v1", Kind: "Pod"}, ObjectMeta: metav1.ObjectMeta{Name: "newpod"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/controller/daemon/update.go
numUnavailable++ continue } switch { case oldPod == nil && newPod == nil, oldPod != nil && newPod != nil: // the manage loop will handle creating or deleting the appropriate pod, consider this unavailable numUnavailable++ case newPod != nil: // this pod is up to date, check its availability if !podutil.IsPodAvailable(newPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
nodeName = newPod.Spec.NodeName newTolerations = newPod.Spec.Tolerations } if oldPod != nil && newPod != nil && helper.Semantic.DeepEqual(oldTolerations, newTolerations) && oldPod.Spec.NodeName == newPod.Spec.NodeName { return } updateItem := podUpdateItem{ podName: podName, podNamespace: podNamespace, nodeName: nodeName, } tc.podUpdateQueue.Add(updateItem) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/replicate_tensor_list_init_ops_pass.cc
for (auto& use : tensor_list.getUses()) { uses.emplace_back(&use); } OpBuilder builder(tensor_list_op.getOperation()); for (OpOperand* operand : uses) { auto new_op = builder.clone(*tensor_list_op.getOperation()); operand->set(new_op->getResult(0)); } } // This transformation pass replicates TensorList initialization ops. class ReplicateTensorListInitOps : public impl::ReplicateTensorListInitOpsPassBase<
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sun Jan 22 17:28:34 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client_test.go
Type: eventtype, Object: newPod(name, phase, message), } } func newEvent(eventtype, message string) watch.Event { return watch.Event{ Type: watch.Added, Object: &v1.Event{ ObjectMeta: metav1.ObjectMeta{ Namespace: metav1.NamespaceDefault, }, Reason: "MockEvent", Message: message, Type: eventtype, }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 8.5K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
"notthere": {Time: currentTime}, // Should be removed, pod deleted. } add(t, dc.pdbStore, pdb) pod1, _ := newPod(t, "p1") pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()} pod2, _ := newPod(t, "p2") pod3, _ := newPod(t, "p3") add(t, dc.podStore, pod1) add(t, dc.podStore, pod2) add(t, dc.podStore, pod3) dc.sync(ctx, pdbName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0)