Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 112 for updateStats (0.61 sec)

  1. pkg/kube/krt/index_test.go

    	}
    	pc.CreateOrUpdateStatus(pod)
    	tt.WaitUnordered("add/namespace/name")
    	assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}})
    
    	pod.Status.PodIP = "1.2.3.5"
    	pc.UpdateStatus(pod)
    	tt.WaitUnordered("update/namespace/name")
    	assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{})
    	assert.Equal(t, fetchSorted("1.2.3.5"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.5"}})
    
    	pod2 := &corev1.Pod{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. pkg/kube/krt/collection_test.go

    	}
    	pc.Create(pod)
    	assert.Equal(t, fetcherSorted(SimplePods)(), nil)
    
    	pod.Status = corev1.PodStatus{PodIP: "1.2.3.4"}
    	pc.UpdateStatus(pod)
    	assert.EventuallyEqual(t, fetcherSorted(SimplePods), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}})
    
    	pod.Status.PodIP = "1.2.3.5"
    	pc.UpdateStatus(pod)
    	assert.EventuallyEqual(t, fetcherSorted(SimplePods), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.5"}})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. pkg/config/schema/codegen/templates/crdclient.go.tmpl

    		}, metav1.UpdateOptions{})
    	{{- end }}
    {{- end }}
    	default:
    		return nil, fmt.Errorf("unsupported type: %v", cfg.GroupVersionKind)
    	}
    }
    
    func updateStatus(c kube.Client, cfg config.Config, objMeta metav1.ObjectMeta) (metav1.Object, error) {
    	switch cfg.GroupVersionKind {
    {{- range .Entries }}
    	{{- if and (not .Resource.Synthetic) (not .Resource.Builtin) (not (eq .StatusType "")) }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. pkg/kube/krt/join_test.go

    			Name:      "svc",
    			Namespace: "namespace",
    		},
    		Spec: corev1.ServiceSpec{Selector: map[string]string{"app": "foo"}},
    	}
    	sc.Create(svc)
    
    	pod.Status = corev1.PodStatus{PodIP: "1.2.3.4"}
    	pc.UpdateStatus(pod)
    
    	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{
    		{pod.Name, svc.Name, pod.Namespace, "1.2.3.4"},
    		{"name-static", svc.Name, pod.Namespace, "9.9.9.9"},
    	})
    
    	ExtraSimplePods.Set(nil)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. pkg/controller/util/node/controller_utils.go

    	pod.Status.Message = fmt.Sprintf(nodepkg.NodeUnreachablePodMessage, nodeName, pod.Name)
    
    	var updatedPod *v1.Pod
    	var err error
    	if updatedPod, err = kubeClient.CoreV1().Pods(pod.Namespace).UpdateStatus(ctx, pod, metav1.UpdateOptions{}); err != nil {
    		return nil, err
    	}
    	return updatedPod, nil
    }
    
    // MarkPodsNotReady updates ready status of given pods running on
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  6. pilot/pkg/config/aggregate/config.go

    	if cr.writer == nil {
    		return "", errorUnsupported
    	}
    	return cr.writer.Update(c)
    }
    
    func (cr *store) UpdateStatus(c config.Config) (string, error) {
    	if cr.writer == nil {
    		return "", errorUnsupported
    	}
    	return cr.writer.UpdateStatus(c)
    }
    
    func (cr *store) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	if cr.writer == nil {
    		return "", errorUnsupported
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go

    			if err != nil {
    				t.Fatalf("unexpected error: %v", err)
    			}
    
    			// UpdateStatus should not update spec.
    			// Check that .spec.num = 10 and .status.num = 20
    			updatedStatusInstance, err := noxuResourceClient.UpdateStatus(context.TODO(), gottenNoxuInstance, metav1.UpdateOptions{})
    			if err != nil {
    				t.Fatalf("unable to update status: %v", err)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 12 17:35:34 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		Status:  apiextensionsv1.ConditionTrue,
    		Reason:  "InstanceDeletionInProgress",
    		Message: "CustomResource deletion is in progress",
    	})
    	crd, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    		// deleted or changed in the meantime, we'll get called again
    		return nil
    	}
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  9. pkg/controller/deployment/sync.go

    		deploymentutil.SetDeploymentCondition(&d.Status, *condition)
    		needsUpdate = true
    	}
    
    	if !needsUpdate {
    		return nil
    	}
    
    	var err error
    	_, err = dc.client.AppsV1().Deployments(d.Namespace).UpdateStatus(ctx, d, metav1.UpdateOptions{})
    	return err
    }
    
    // getAllReplicaSetsAndSyncRevision returns all the replica sets for the provided deployment (new and all old), with new RS's and deployment's revision updated.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 24.5K bytes
    - Viewed (0)
  10. pkg/controller/certificates/signer/signer.go

    			Status:         v1.ConditionTrue,
    			Reason:         "SignerValidationFailure",
    			Message:        err.Error(),
    			LastUpdateTime: metav1.Now(),
    		})
    		_, err = s.client.CertificatesV1().CertificateSigningRequests().UpdateStatus(ctx, csr, metav1.UpdateOptions{})
    		if err != nil {
    			return fmt.Errorf("error adding failure condition for csr: %v", err)
    		}
    		return nil
    	} else if !recognized {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 03:26:08 UTC 2023
    - 10.3K bytes
    - Viewed (0)
Back to top