emansije/kube-metrics-adapter
1
0
Fork 0
forked from yusheng-guo/kube-metrics-adapter
Code Pull Requests Activity

Removed debug message, changed podReadyAge >= c.minPodReadyAge

Browse Source 
Signed-off-by: Anatolii Dutchak <adutchak-x@tunein.com>
This commit is contained in:
Anatolii Dutchak
2021-04-20 12:33:39 +03:00
parent b9300d1e46
commit 5aa2272e37
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/collector/pod_collector.go
View File

@ -99,7 +99,7 @@ func (c *PodCollector) GetMetrics() ([]CollectedMetric, error) {
isPodReady, podReadyAge := GetPodReadyAge(pod) isPodReady, podReadyAge := GetPodReadyAge(pod)
if isPodReady { if isPodReady {
if podReadyAge > c.minPodReadyAge { if podReadyAge >= c.minPodReadyAge {
go c.getPodMetric(pod, ch, errCh) go c.getPodMetric(pod, ch, errCh)
} else { } else {
skippedPodsCount++ skippedPodsCount++
@ -182,7 +182,6 @@ func GetPodReadyAge(pod corev1.Pod) (bool, time.Duration) {
for i := range conditions { for i := range conditions {
if conditions[i].Type == corev1.PodReady { if conditions[i].Type == corev1.PodReady {
podReadyAge = time.Since(conditions[i].LastTransitionTime.Time) podReadyAge = time.Since(conditions[i].LastTransitionTime.Time)
fmt.Printf("podReadyAge: %s", podReadyAge)
return true, podReadyAge return true, podReadyAge
} }
} }