seecoder-paas/src/main/java/cn/seecoder/paas/util/K8sApiConfiguration.java

package cn.seecoder.paas.util;

import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.kubernetes.client.DefaultKubernetesClient;
import io.kubernetes.client.Exec;
import io.kubernetes.client.openapi.ApiClient;
import io.kubernetes.client.openapi.apis.AppsV1Api;
import io.kubernetes.client.openapi.apis.CoreV1Api;
import io.kubernetes.client.openapi.apis.ExtensionsV1beta1Api;
import io.kubernetes.client.util.Config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
public class K8sApiConfiguration {

    private final ApiClient apiClient;

    private final CoreV1Api coreV1Api;

    private final AppsV1Api appsV1Api;

    private final ExtensionsV1beta1Api extensionsV1beta1Api;

    private final Exec exec;

    /**
     * http读取的超时时间设置为7分钟
     */
    private final ApiClient watchApiClient;

    private final CoreV1Api watchCoreV1Api;

    private final AppsV1Api watchAppsV1Api;

    private DefaultKubernetesClient fabricK8sClient;

    @Autowired
    public K8sApiConfiguration(ApplicationProperties applicationProperties) {
        ApplicationProperties.K8s k8s = applicationProperties.getK8s();
        this.apiClient = Config.fromToken(k8s.getApiServer(), k8s.getToken(), k8s.isValidateSSL());
        this.apiClient.setDebugging(k8s.isDebug());
        io.kubernetes.client.openapi.Configuration.setDefaultApiClient(this.apiClient);
        this.coreV1Api = new CoreV1Api();
        this.appsV1Api = new AppsV1Api();
        this.extensionsV1beta1Api = new ExtensionsV1beta1Api();
        this.exec = new Exec();


        this.watchApiClient = Config.fromToken(k8s.getApiServer(), k8s.getToken(), k8s.isValidateSSL());
        this.watchCoreV1Api = new CoreV1Api(watchApiClient);
        this.watchAppsV1Api = new AppsV1Api(watchApiClient);

        // fabric client
        io.fabric8.kubernetes.client.Config config = new ConfigBuilder().withMasterUrl(k8s.getApiServer()).withOauthToken(k8s.getToken()).withTrustCerts(!k8s.isValidateSSL()).build();
        this.fabricK8sClient = new DefaultKubernetesClient(config);
    }

    @Bean
    public DefaultKubernetesClient fabricK8sClient() {
        return this.fabricK8sClient;
    }

    @Bean
    public ApiClient apiClient() {
        return apiClient;
    }

    @Bean
    public CoreV1Api coreV1Api() {
        return coreV1Api;
    }

    @Bean
    public AppsV1Api appsV1Api() {
        return appsV1Api;
    }

    @Bean
    public ExtensionsV1beta1Api extensionsV1beta1Api() {
        return extensionsV1beta1Api;
    }

    @Bean
    public Exec exec() {
        return exec;
    }


    @Bean
    public ApiClient watchApiClient() {
        return watchApiClient;
    }

    @Bean
    public CoreV1Api watchCoreV1Api() {
        return watchCoreV1Api;
    }

    @Bean
    public AppsV1Api watchAppsV1Api() {
        return watchAppsV1Api;
    }
}