- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 142 for newNode (0.67 sec)
-
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) -
subprojects/diagnostics/src/main/resources/org/gradle/api/tasks/diagnostics/htmldependencyreport/jquery.jstree.js
initially_open : [], initially_load : [], open_parents : true, notify_plugins : true, rtl : false, load_open : false, strings : { loading : "Loading ...", new_node : "New node", multiple_selection : "Multiple selection" } }, _fn : { init : function () { this.set_focus(); if(this._get_settings().core.rtl) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 04 09:03:42 UTC 2021 - 49.5K 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) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
server := httptest.NewServer(handler) defer server.Close() client := http.Client{} simple := &genericapitesting.Simple{} //using newCodec and send the request to testVersion URL shall cause a discrepancy in apiVersion data, err := runtime.Encode(newCodec, simple) if err != nil { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K 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) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
return undefined;},get mode(){return this.currentMode_;},set mode(newMode){if(newMode!==undefined){if(typeof newMode!=='number'){throw new Error('Mode must be a number');} if((newMode&this.supportedModeMask_)===0){throw new Error('Cannot switch to this mode, it is not supported');} if(MOUSE_SELECTOR_MODE_INFOS[newMode]===undefined){throw new Error('Unrecognized mode');}}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// DeleteNominatedPodIfExists deletes nominatedPod from internal cache. It's a no-op if it doesn't exist. DeleteNominatedPodIfExists(pod *v1.Pod) // UpdateNominatedPod updates the <oldPod> with <newPod>. UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *PodInfo) // NominatedPodsForNode returns nominatedPods on the given node. NominatedPodsForNode(nodeName string) []*PodInfo }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
spec := v1.PodSpec{NodeName: string(kl.nodeName), Containers: []v1.Container{{Ports: []v1.ContainerPort{{HostPort: 80}}}}} pods := []*v1.Pod{ podWithUIDNameNsSpec("123456789", "newpod", "foo", spec), podWithUIDNameNsSpec("987654321", "oldpod", "foo", spec), } // Make sure the Pods are in the reverse order of creation time. pods[1].CreationTimestamp = metav1.NewTime(time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)