Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for thresholdsFirstObservedAt (0.25 sec)

  1. pkg/kubelet/eviction/eviction_manager.go

    	}
    	debugLogThresholdsWithObservation("thresholds - reclaim not satisfied", thresholds, observations)
    
    	// track when a threshold was first observed
    	now := m.clock.Now()
    	thresholdsFirstObservedAt := thresholdsFirstObservedAt(thresholds, m.thresholdsFirstObservedAt, now)
    
    	// the set of node conditions that are triggered by currently observed thresholds
    	nodeConditions := nodeConditions(thresholds)
    	if len(nodeConditions) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/eviction_manager_test.go

    					summaryProvider:              summaryProvider,
    					nodeRef:                      nodeRef,
    					nodeConditionsLastObservedAt: nodeConditionsObservedAt{},
    					thresholdsFirstObservedAt:    thresholdsObservedAt{},
    				}
    
    				// synchronize to detect the memory pressure
    				_, err := manager.synchronize(diskInfoProvider, activePodsFunc)
    
    				if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  3. pkg/kubelet/eviction/helpers.go

    			results = append(results, threshold)
    		}
    	}
    	return results
    }
    
    // thresholdsFirstObservedAt merges the input set of thresholds with the previous observation to determine when active set of thresholds were initially met.
    func thresholdsFirstObservedAt(thresholds []evictionapi.Threshold, lastObservedAt thresholdsObservedAt, now time.Time) thresholdsObservedAt {
    	results := thresholdsObservedAt{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 53.6K bytes
    - Viewed (0)
  4. pkg/kubelet/eviction/helpers_test.go

    			},
    			now: now.Time,
    			result: thresholdsObservedAt{
    				hardThreshold: oldTime.Time,
    			},
    		},
    	}
    	for testName, testCase := range testCases {
    		actual := thresholdsFirstObservedAt(testCase.thresholds, testCase.lastObservedAt, testCase.now)
    		if !reflect.DeepEqual(actual, testCase.result) {
    			t.Errorf("Test case: %s, expected: %v, actual: %v", testName, testCase.result, actual)
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
Back to top