Проблема с использованием конфигурации kubernetes в кластере с библиотекой client-go в облачной сборке Google - PullRequest
Новая
       33

Проблема с использованием конфигурации kubernetes в кластере с библиотекой client-go в облачной сборке Google

0 голосов
/ 14 марта 2019

У меня возникли сложности с попыткой создать приложение, использующее библиотеку golang client-go. Приложение обеспечивает и API, который затем развертывает модуль в кластере kubernetes. Теперь приложение может успешно развернуть модуль, если я использую конфигурацию kubernetes (т.е. minikube) вне кластера, которая находится в $ HOME / .kube / config. См. Код ниже, который определяет, какую конфигурацию использовать в зависимости от пути конфигурации; 

package kubernetesinterface

import (
    "log"
    "os"

    core "k8s.io/api/core/v1"
    v1 "k8s.io/apimachinery/pkg/apis/meta/v1"

    "k8s.io/client-go/kubernetes"
    _ "k8s.io/client-go/plugin/pkg/client/auth" // load auth packages
    "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/clientcmd"
)

// KubeStruct - struct that uses interface type (useful when testing)
type KubeStruct struct {
    clientset kubernetes.Interface
}

// DeployPod - Method that uses a KubeStruct type to deploy deploy simulator pod to kubernetes cluster
func (kube *KubeStruct) DeployPod() bool {
    var podObject *core.Pod
    podObject = createPodObjects()
    _, err := kube.clientset.Core().Pods(podObject.Namespace).Create(podObject)
    if err != nil {
        log.Println("Failed to create simulator pod: ", err.Error())
        return false
    }

    return true
}

// GetNewClient - function to create a new clientset object to connect to a kubernetes cluster
func GetNewClient() (*KubeStruct, error) {
    var kubeConfig *rest.Config
    var err error
    configPath := os.Getenv("CONFIG_PATH")
    if configPath == "" {
        log.Println("Using in-cluster configuration")
        kubeConfig, err = rest.InClusterConfig()
    } else {
        log.Println("Using out of cluster config")
        kubeConfig, err = clientcmd.BuildConfigFromFlags("", configPath)
    }
    if err != nil {
        log.Println("Error getting configuration ", err.Error())
        return nil, err
    }
    // create clientset for kubernetes cluster
    client := KubeStruct{}
    client.clientset, err = kubernetes.NewForConfig(kubeConfig)
    if err != nil {
        log.Println("Error creating clientset for kubernetes cluster ", err.Error())
        return nil, err
    }

    return &client, nil

}

func createPodObjects() *core.Pod {
    return &core.Pod{
        ObjectMeta: v1.ObjectMeta{
            Name:      "podname",
            Namespace: "default",
            Labels: map[string]string{
                "app": "podname",
            },
        },
        Spec: core.PodSpec{
            Containers: []core.Container{
                {
                    Name:            "podname",
                    Image:           os.Getenv("IMAGE"),
                    ImagePullPolicy: core.PullIfNotPresent,
                    Command: []string{
                        "sleep",
                        "3600",
                    },
                },
            },
        },
    }
}

Таким образом, если существует значение для CONFIG_PATH, приложение работает как положено, и модуль развернут в моем кластере мини-кубов. Теперь, когда то же приложение построено на gcp, я получаю следующую ошибку сборки: 

Step #1: 2019/03/13 21:25:20 Error getting configuration unable to load in-cluster configuration, KUBERNETES_SERVICE_HOST and KUBERNETES_SERVICE_PORT must be defined

Я безуспешно искал в Интернете решение, поэтому решил опубликовать здесь.

...