- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 123 for updateStats (0.34 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/fake/fake_customresourcedefinition.go
if obj == nil { return emptyResult, err } return obj.(*v1beta1.CustomResourceDefinition), err } // UpdateStatus was generated because the type contains a Status member. // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kube/kclient/interfaces.go
Create(object T) (T, error) // Update updates a resource, returning the newly applied resource. Update(object T) (T, error) // UpdateStatus updates a resource's status, returning the newly applied resource. UpdateStatus(object T) (T, error) // Patch patches the resource, returning the newly applied resource. Patch(name, namespace string, pt apitypes.PatchType, data []byte) (T, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:09:57 UTC 2024 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake/fake_customresourcedefinition.go
if obj == nil { return emptyResult, err } return obj.(*v1.CustomResourceDefinition), err } // UpdateStatus was generated because the type contains a Status member. // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 8.4K bytes - Viewed (0) -
tensorflow/cc/framework/scope.cc
return impl()->graph_; } Status Scope::status() const { return *impl()->status_; } const std::vector<Operation>& Scope::control_deps() const { return impl()->control_deps_; } void Scope::UpdateStatus(const Status& s) const { impl()->status_->Update(s); if (impl()->exit_on_error_ && !ok()) { LOG(FATAL) << *impl()->status_; } }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 05:57:22 UTC 2024 - 20.9K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)