- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 62 for newNode (0.2 sec)
-
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
newPod := createPodWithVolume("dswp-test-pod", "dswp-test-volume-name", "file-bound", []v1.Container{newContainer}) // Act - add the new Pod fakePodManager.AddPod(newPod) dswp.findAndAddNewPods() // Assert // Check the global volume state uniquePodName := types.UniquePodName(newPod.UID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
return nil } newPod := pod.DeepCopy() updated := apipod.UpdatePodCondition(&newPod.Status, &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionFalse, }) if !updated { return nil } if _, err := dc.kubeClient.CoreV1().Pods(pod.Namespace).UpdateStatus(ctx, newPod, metav1.UpdateOptions{}); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
src/go/doc/example.go
} // Copy body and comments, as the originals may be used elsewhere. newBody := &ast.BlockStmt{ Lbrace: body.Lbrace, List: body.List, Rbrace: last.Pos(), } newComments := make([]*ast.CommentGroup, len(comments)-1) copy(newComments, comments[:i]) copy(newComments[i:], comments[i+1:]) return newBody, newComments } // lastComment returns the last comment inside the provided block.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
check(!responseBodyOpen) check(!requestBodyOpen) } val exchangeFinder = this.exchangeFinder!! val connection = exchangeFinder.find() val codec = connection.newCodec(client, chain) val result = Exchange(this, eventListener, exchangeFinder, codec) this.interceptorScopedExchange = result this.exchange = result this.withLock { this.requestBodyOpen = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
utilruntime.Must(example.AddToScheme(scheme)) utilruntime.Must(examplev1.AddToScheme(scheme)) grpclog.SetLoggerV2(grpclog.NewLoggerV2(ioutil.Discard, ioutil.Discard, os.Stderr)) } func newPod() runtime.Object { return &example.Pod{} } func newPodList() runtime.Object { return &example.PodList{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
if err := store.GuaranteedUpdate(ctx, key, storedObj, false, nil, func(_ runtime.Object, _ storage.ResponseMeta) (runtime.Object, *uint64, error) { newPod := prevStoredObj.DeepCopy() newPod.Annotations = map[string]string{"version": "second"} return newPod, nil, nil }, nil); err != nil { t.Fatalf("update failed: %v", err) } objRV, _ := strconv.Atoi(storedObj.ResourceVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if err != nil { t.Fatal(err) } newPod, ok := obj.(*example.Pod) if !ok { t.Fatalf("unexpected object: %#v", obj) } // update the object should not fail precondition newPod.Spec.NodeName = "machine2" res, _, err := registry.Update(ctx, podName, rest.DefaultUpdatedObjectInfo(newPod), rest.ValidateAllObjectFunc, rest.ValidateAllObjectUpdateFunc, false, &metav1.UpdateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
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) -
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)