Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for inProgressResources (0.31 sec)

  1. pilot/pkg/status/distribution/reporter.go

    			dpVersion, err := r.ledger.GetPreviousValue(nonce, res.ToModelKey())
    			if err == nil && dpVersion == res.Generation {
    				if _, ok := out.InProgressResources[key]; !ok {
    					out.InProgressResources[key] = len(dataplanes)
    				} else {
    					out.InProgressResources[key] += len(dataplanes)
    				}
    			} else if err != nil {
    				scope.Errorf("Encountered error retrieving version %s of key %s from Store: %v", nonce, key, err)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 30 17:25:17 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. pilot/pkg/status/distribution/reporter_test.go

    	rpt, prunes := r.buildReport()
    	r.removeCompletedResource(prunes)
    	Expect(rpt.DataPlaneCount).To(Equal(2))
    	Expect(rpt.InProgressResources).To(Equal(map[string]int{
    		myResources[0].String(): 2,
    		myResources[1].String(): 1,
    		myResources[2].String(): 2,
    	}))
    	Expect(r.inProgressResources).NotTo(ContainElement(resources[0]))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 30 17:25:17 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top