From eb36aaf916de7d529aaa5ac1262148d72b1015c7 Mon Sep 17 00:00:00 2001 From: vimystic <122659254+vimystic@users.noreply.github.com> Date: Tue, 2 Apr 2024 15:03:12 -0600 Subject: [PATCH] update --- internal/fullnode/stuck_detection.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/internal/fullnode/stuck_detection.go b/internal/fullnode/stuck_detection.go index 0c95576d..64cbaa6d 100644 --- a/internal/fullnode/stuck_detection.go +++ b/internal/fullnode/stuck_detection.go @@ -5,23 +5,25 @@ import ( "fmt" "io" "strings" + "time" cosmosv1 "github.com/strangelove-ventures/cosmos-operator/api/v1" "github.com/strangelove-ventures/cosmos-operator/internal/kube" corev1 "k8s.io/api/core/v1" + "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" "sigs.k8s.io/controller-runtime/pkg/client" ) type StuckPodDetection struct { - //available func(pods []*corev1.Pod, minReady time.Duration, now time.Time) []*corev1.Pod - collector StatusCollector - //computeRollout func(maxUnavail *intstr.IntOrString, desired, ready int) int + available func(pods []*corev1.Pod, minReady time.Duration, now time.Time) []*corev1.Pod + collector StatusCollector + computeRollout func(maxUnavail *intstr.IntOrString, desired, ready int) int } -func NewStuckDetection(collector StatusCollector) DriftDetection { - return DriftDetection{ +func NewStuckDetection(collector StatusCollector) StuckPodDetection { + return StuckPodDetection{ available: kube.AvailablePods, collector: collector, computeRollout: kube.ComputeRollout,