- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for updateStats (0.27 sec)
-
pkg/kubelet/server/server_test.go
} func (*fakeKubelet) RlimitStats() (*statsapi.RlimitStats, error) { return nil, nil } func (*fakeKubelet) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) { return nil, nil, nil } func (*fakeKubelet) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) { return nil, nil } type fakeAuth struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/types.gen.go
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 { case gvk.AuthorizationPolicy: return c.Istio().SecurityV1beta1().AuthorizationPolicies(cfg.Namespace).UpdateStatus(context.TODO(), &apiistioioapisecurityv1beta1.AuthorizationPolicy{ ObjectMeta: objMeta,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 62.2K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
return nil } return a.updateStatus(ctx, newHPA) } // updateStatus actually does the update request for the status of the given HPA func (a *HorizontalController) updateStatus(ctx context.Context, hpa *autoscalingv2.HorizontalPodAutoscaler) error { _, err := a.hpaNamespacer.HorizontalPodAutoscalers(hpa.Namespace).UpdateStatus(ctx, hpa, metav1.UpdateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
t.Errorf("%s: expected requeueAfter: %+v, got requeueAfter time: %+v", name, tc.expectedRequeueDuration, requeueAfter) } } if updateStatus != tc.expectUpdateStatus { t.Errorf("%s: expected updateStatus: %t, actually: %t", name, tc.expectUpdateStatus, updateStatus) } expectedCreates := 0 if tc.expectCreate { expectedCreates = 1 } if tc.ranPreviously && !tc.stillActive {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
setPodUnready(pod) _, err := kube.CoreV1().Pods(pod.Namespace).UpdateStatus(context.TODO(), pod, metav1.UpdateOptions{}) if err != nil { t.Fatal(err) } expectServiceEndpoints(t, fx, expectedSvc, 80, []EndpointResponse{}) setPodReady(pod) _, err = kube.CoreV1().Pods(pod.Namespace).UpdateStatus(context.TODO(), pod, metav1.UpdateOptions{}) if err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
tensorflow/compiler/jit/deadness_analysis_test.cc
.Input(_data) .Input(_output_index) .Attr("num_outs", num_outs); scope.UpdateBuilder(&builder); scope.UpdateStatus(builder.Finalize(scope.graph(), &ret)); if (!scope.ok()) return; scope.UpdateStatus(scope.DoShapeInference(ret)); for (int32_t i = 0; i < ret->num_outputs(); ++i) { outputs->push_back(Output(ret, i)); } }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
return claim, nil } newClaim, err := ctrl.kubeClient.CoreV1().PersistentVolumeClaims(claimClone.Namespace).UpdateStatus(ctx, claimClone, metav1.UpdateOptions{}) if err != nil { logger.V(4).Info("Updating PersistentVolumeClaim status, set phase failed", "PVC", klog.KObj(claim), "phase", phase, "err", err) return newClaim, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
_, currentReadyCondition = controllerutil.GetNodeCondition(&node.Status, v1.NodeReady) if !apiequality.Semantic.DeepEqual(currentReadyCondition, &observedReadyCondition) { if _, err := nc.kubeClient.CoreV1().Nodes().UpdateStatus(ctx, node, metav1.UpdateOptions{}); err != nil { logger.Error(err, "Error updating node", "node", klog.KObj(node)) return gracePeriod, observedReadyCondition, currentReadyCondition, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
toUpdate.Status.NumberAvailable = int32(numberAvailable) toUpdate.Status.NumberUnavailable = int32(numberUnavailable) if _, updateErr = dsClient.UpdateStatus(ctx, toUpdate, metav1.UpdateOptions{}); updateErr == nil { return nil } // Stop retrying if we exceed statusUpdateRetries - the DaemonSet will be requeued with a rate limit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = phase newPod.Status.PodIPs = []corev1.PodIP{ { IP: ip, }, } s.pc.UpdateStatus(newPod) } else { s.pc.Update(pod) } } // just overwrites the labels // nolint: unparam func (s *ambientTestServer) labelPod(t *testing.T, name, ns string, labels map[string]string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)