Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for updateStats (0.25 sec)

  1. pkg/kubelet/kubelet.go

    func (kl *Kubelet) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error) {
    	return kl.StatsProvider.GetCgroupStats(cgroupName, updateStats)
    }
    
    // GetCgroupCPUAndMemoryStats is delegated to StatsProvider, which implements stats.Provider interface
    func (kl *Kubelet) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/helpers_test.go

    				}
    			}
    
    		})
    	}
    }
    
    type fakeSummaryProvider struct {
    	result *statsapi.Summary
    }
    
    func (f *fakeSummaryProvider) Get(ctx context.Context, updateStats bool) (*statsapi.Summary, error) {
    	return f.result, nil
    }
    
    func (f *fakeSummaryProvider) GetCPUAndMemoryStats(ctx context.Context) (*statsapi.Summary, error) {
    	return f.result, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    						peerResults[nerr.Host.String()] = prs
    					}
    					continue
    				}
    			}
    		}
    	}
    
    	for _, pr := range peerResults {
    		updateStatus.Results = append(updateStatus.Results, pr)
    	}
    
    	// Marshal API response
    	jsonBytes, err := json.Marshal(updateStatus)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseJSON(w, jsonBytes)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  4. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    	node0.Status = newNodeStatus
    	node1.Status = healthyNodeNewStatus
    	_, err = fakeNodeHandler.UpdateStatus(ctx, node0, metav1.UpdateOptions{})
    	if err != nil {
    		t.Errorf(err.Error())
    		return
    	}
    	_, err = fakeNodeHandler.UpdateStatus(ctx, node1, metav1.UpdateOptions{})
    	if err != nil {
    		t.Errorf(err.Error())
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. pkg/controller/job/job_controller_test.go

    	job.Status.Conditions = append(job.Status.Conditions, batch.JobCondition{
    		Type:   batch.JobComplete,
    		Status: v1.ConditionTrue,
    	})
    	_, err = clientset.BatchV1().Jobs(job.GetNamespace()).UpdateStatus(ctx, job, metav1.UpdateOptions{})
    	if err != nil {
    		t.Fatalf("Updating job status: %v", err)
    	}
    
    	// Verify the pod finalizer is removed for a finished Job,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top