- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 64 for newNode (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
GroupResource: schema.GroupResource{Resource: "pods"}, ResourcePrefix: setupOpts.resourcePrefix, KeyFunc: setupOpts.keyFunc, GetAttrsFunc: GetPodAttrs, NewFunc: newPod, NewListFunc: newPodList, IndexerFuncs: setupOpts.indexerFuncs, Codec: codecs.LegacyCodec(examplev1.SchemeGroupVersion), Clock: setupOpts.clock, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
t.Errorf("status does not match: %v, want: %v", gotStatus, test.wantStatus) } }) } } func TestRestartableInitContainers(t *testing.T) { newPod := func() *v1.Pod { return &v1.Pod{ Spec: v1.PodSpec{ Containers: []v1.Container{ {Name: "regular"}, }, }, } } newPodWithRestartableInitContainers := func() *v1.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
tensorflow/c/c_api.cc
// executing the following code. for (int i = first_new_node_id; i < parent->graph.num_node_ids(); ++i) { Node* new_node = parent->graph.FindNodeId(i); if (new_node == nullptr) continue; parent->name_map[new_node->name()] = new_node; } // Populate 'outputs'. DCHECK_LE(loop_outputs.size(), num_loop_vars); for (int i = 0; i < loop_outputs.size(); ++i) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 03:35:10 UTC 2024 - 102.3K bytes - Viewed (0) -
src/net/http/request_test.go
continue } slurp1, err := io.ReadAll(req.Body) if err != nil { t.Errorf("test[%d]: ReadAll(Body) = %v", i, err) } newBody, err := req.GetBody() if err != nil { t.Errorf("test[%d]: GetBody = %v", i, err) } slurp2, err := io.ReadAll(newBody) if err != nil { t.Errorf("test[%d]: ReadAll(GetBody()) = %v", i, err) } if string(slurp1) != string(slurp2) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 18:42:34 UTC 2024 - 44K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
t.Errorf("want %v got %v", updateSet.Spec.Template, restoredUpdateSet.Spec.Template) } } func TestGetPersistentVolumeClaims(t *testing.T) { // nil inherits statefulset labels pod := newPod() statefulSet := newStatefulSet(1) statefulSet.Spec.Selector.MatchLabels = nil claims := getPersistentVolumeClaims(statefulSet, pod) pvc := newPVC("datadir-foo-0")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
cmd/batch-handlers.go
} u, err := url.Parse(r.Target.Endpoint) if err != nil { return err } cred := r.Target.Creds c, err := miniogo.NewCore(u.Host, &miniogo.Options{ Creds: credentials.NewStaticV4(cred.AccessKey, cred.SecretKey, cred.SessionToken), Secure: u.Scheme == "https", Transport: getRemoteInstanceTransport(),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
"oldPodUID", uid, "podUID", translatedUID) m.deletePodStatus(uid) return } mergedStatus := mergePodStatus(pod.Status, status.status, m.podDeletionSafety.PodCouldHaveRunningContainers(pod)) newPod, patchBytes, unchanged, err := statusutil.PatchPodStatus(context.TODO(), m.kubeClient, pod.Namespace, pod.Name, pod.UID, pod.Status, mergedStatus)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
} type activePodsStub struct { activePods []*v1.Pod } func (a *activePodsStub) getActivePods() []*v1.Pod { return a.activePods } func (a *activePodsStub) updateActivePods(newPods []*v1.Pod) { a.activePods = newPods } type MockEndpoint struct { getPreferredAllocationFunc func(available, mustInclude []string, size int) (*pluginapi.PreferredAllocationResponse, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
decodeSerializer := s.Serializer if validationDirective == metav1.FieldValidationWarn || validationDirective == metav1.FieldValidationStrict { decodeSerializer = s.StrictSerializer } codec := runtime.NewCodec( scope.Serializer.EncoderForVersion(s.Serializer, gv), scope.Serializer.DecoderToVersion(decodeSerializer, scope.HubGroupVersion), ) userInfo, _ := request.UserFrom(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
src/encoding/gob/encoder_test.go
return r } return cmp.Compare(a.value, b.value) }) return entries } got := readMap(out) want := readMap(in) if !reflect.DeepEqual(got, want) { t.Fatalf("\nEncode: %v\nDecode: %v", want, got) } } func TestDecodePartial(t *testing.T) { type T struct { X []int Y string } var buf bytes.Buffer t1 := T{X: []int{1, 2, 3}, Y: "foo"}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 29.7K bytes - Viewed (0)