- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 123 for updateStats (0.21 sec)
-
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) -
cmd/site-replication.go
defer func() { if err != nil { rs.Status = ResyncFailed saveSiteResyncMetadata(ctx, rs, objAPI) globalSiteResyncMetrics.updateState(rs) } }() if err := globalSiteResyncMetrics.updateState(rs); err != nil { return res, err } for _, bi := range buckets { bucket := bi.Name
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.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) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
// events - since PodIP will be "". newPod.Status.PodIP = pod.Status.PodIP newPod.Status.Phase = corev1.PodRunning pc.UpdateStatus(newPod) waitForPod(t, controller, pod.Status.PodIP) // pod first time occur will trigger proxy push fx.WaitOrFail(t, "proxy") } } func setPodReady(pod *corev1.Pod) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
} logger.V(5).Info("Requesting deallocation of ResourceClaim", "pod", klog.KObj(pod), "resourceclaim", klog.KObj(claim)) if _, err := pl.clientset.ResourceV1alpha2().ResourceClaims(claim.Namespace).UpdateStatus(ctx, claim, metav1.UpdateOptions{}); err != nil { return nil, statusError(logger, err) } return nil, framework.NewStatus(framework.Unschedulable, "deallocation of ResourceClaim completed") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
} // updateJobStatus calls the API to update the job status. func (jm *Controller) updateJobStatus(ctx context.Context, job *batch.Job) (*batch.Job, error) { return jm.kubeClient.BatchV1().Jobs(job.Namespace).UpdateStatus(ctx, job, metav1.UpdateOptions{}) } func (jm *Controller) patchJob(ctx context.Context, job *batch.Job, data []byte) error { _, err := jm.kubeClient.BatchV1().Jobs(job.Namespace).Patch(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/resources/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/uikit.min.js
Ne("["+this.attrItem+"],[data-"+this.attrItem+"]",e)},watch:function(){var e=this;if(this.updateState(),!1!==this.selActive){var i=Ne(this.selActive,this.$el);this.toggles.forEach(function(t){return He(t,e.cls,b(i,t))})}},immediate:!0},target:function(t,e){return Ce(t.target,e)},children:{get:function(){return Ot(this.target)},watch:function(t,e){var i,n;n=e,(i=t).length===n.length&&i.every(function(t){return~n.indexOf(t)})||this.updateState()}}},events:[{name:"click",delegate:function(){return"["+this.attrItem+"...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 130.5K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
} if getCalled != tt.expectedGetCalled { t.Errorf("Get() was called %v times, expected %v times", getCalled, tt.expectedGetCalled) } if updateCalled != tt.expectedUpdateCalled { t.Errorf("UpdateStatus() was called %v times, expected %v times", updateCalled, tt.expectedUpdateCalled) } }) } } func TestShouldIgnoreNodeUpdate(t *testing.T) { cases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
Lkotlinx/coroutines/internal/SystemPropsKt__SystemPropsKt; Lkotlinx/coroutines/internal/ThreadContextKt$countAll$1; Lkotlinx/coroutines/internal/ThreadContextKt$findOne$1; Lkotlinx/coroutines/internal/ThreadContextKt$updateState$1; Lkotlinx/coroutines/internal/ThreadContextKt; Lkotlinx/coroutines/internal/ThreadSafeHeap; Lkotlinx/coroutines/internal/ThreadSafeHeapNode; Lkotlinx/coroutines/internal/ThreadState;
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (1) -
CHANGELOG/CHANGELOG-1.4.md
* Fixes memory/goroutine leak in Federation Service controller. ([#33359](https://github.com/kubernetes/kubernetes/pull/33359), [@shashidharatd](https://github.com/shashidharatd)) * Use UpdateStatus, not Update, to add LoadBalancerStatus to Federated Ingress. ([#33605](https://github.com/kubernetes/kubernetes/pull/33605), [@quinton-hoole](https://github.com/quinton-hoole))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0)