Adjust controller file structure to match logical

Signed-off-by: Mike Spreitzer <mspreitz@us.ibm.com>

Author: MikeSpreitzer

pkg/controller/dual-pods/controller.go

@@ -23,8 +23,6 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/spf13/pflag"
-
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -69,14 +67,6 @@ type Controller interface {
 	Start(context.Context) error
 }
 
-type CommonConfig struct {
-	Verbosity int // `-v`
-}
-
-func (cc *CommonConfig) AddToFlagSet(name string, flags *pflag.FlagSet) {
-	flags.IntVar(&cc.Verbosity, name+"-verbosity", cc.Verbosity, "-v setting for "+name)
-}
-
 // NewController makes a new dual pods controller.
 // The given namespace is the one to focus on.
 func NewController(

…ontroller/dual-pods/server-requesting.go …controller/dual-pods/inference-server.gopkg/controller/dual-pods/server-requesting.go renamed to pkg/controller/dual-pods/inference-server.go pkg/controller/dual-pods/server-requesting.go renamed to pkg/controller/dual-pods/inference-server.go

@@ -365,6 +365,42 @@ func (ctl *controller) ensureReqStatus(ctx context.Context, requestingPod *corev
 	return err, false
 }
 
+func GetOwner(pod *corev1.Pod) (infSvrItem, bool) {
+	ownerRef := metav1.GetControllerOfNoCopy(pod)
+	if ownerRef != nil && ownerRef.Kind == "Pod" {
+		return infSvrItem{ownerRef.UID, ownerRef.Name}, true
+	}
+	return infSvrItem{}, false
+}
+
+func postToReadiness(url string) error {
+	client := &http.Client{
+		Timeout: 5 * time.Second,
+	}
+
+	resp, err := client.Post(url, "application/json", nil)
+	if err != nil {
+		return fmt.Errorf("http post %q: %w", url, err)
+	}
+	defer resp.Body.Close() //nolint:errcheck
+
+	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
+		body, _ := io.ReadAll(resp.Body)
+		return fmt.Errorf("unexpected status %d: %s", resp.StatusCode, string(body))
+	}
+
+	return nil
+}
+
+func isPodReady(pod *corev1.Pod) bool {
+	for _, cond := range pod.Status.Conditions {
+		if cond.Type == corev1.PodReady && cond.Status == corev1.ConditionTrue {
+			return true
+		}
+	}
+	return false
+}
+
 var coreScheme *k8sruntime.Scheme
 var codecFactory k8sserializer.CodecFactory
 var podDecoder k8sruntime.Decoder