Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 142 for newNode (0.67 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top