Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for newNode (0.3 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        return peerCertificates.isNotEmpty() &&
          OkHostnameVerifier.verify(url.host, peerCertificates[0] as X509Certificate)
      }
    
      @Throws(SocketException::class)
      internal fun newCodec(
        client: OkHttpClient,
        chain: RealInterceptorChain,
      ): ExchangeCodec {
        val socket = this.socket!!
        val source = this.source!!
        val sink = this.sink!!
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  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. 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)
  7. 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)
Back to top