alibaba/kt-connect

Function execute has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func execute(method string, url *url.URL, config *restclient.Config, stdin io.Reader, stdout, stderr io.Writer, tty bool) error {

Method Kubernetes.waitPodsReady has 5 return statements (exceeds 4 allowed).

Open

func (k *Kubernetes) waitPodsReady(labels map[string]string, namespace string, timeoutSec int, times int) ([]coreV1.Pod, error) {
    pods, err := k.GetPodsByLabel(labels, namespace)
    if err != nil {
        return nil, err
    }

Similar blocks of code found in 4 locations. Consider refactoring.

Open

func (k *Kubernetes) UpdatePodHeartBeat(name, namespace string) {
    key := "pod_" + name
    if _, err := k.Clientset.CoreV1().Pods(namespace).
        Patch(context.TODO(), name, types.JSONPatchType, []byte(resourceHeartbeatPatch()), metav1.PatchOptions{}); err != nil {
        if healthy, exists := LastHeartBeatStatus.Get(key); healthy || !exists {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (k *Kubernetes) IncreasePodRef(name string, namespace string) error {
    pod, err := k.GetPod(name, namespace)
    if err != nil {
        return err
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (k *Kubernetes) WatchPod(name, namespace string, fAdd, fDel, fMod func(*coreV1.Pod)) {
    k.watchResource(name, namespace, string(coreV1.ResourcePods), &coreV1.Pod{},
        func(obj any) {
            handlePodEvent(obj, "added", fAdd)
        },

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func handlePodEvent(obj any, status string, f func(*coreV1.Pod)) {
    switch obj.(type) {
    case *coreV1.Pod:
        if f != nil {
            log.Debug().Msgf("Pod %s %s", obj.(*coreV1.Pod).Name, status)

• Read up
  Read up