前言

使用kubernetes-client访问k8s apiserver，直接贴代码了

配置类ApiClientConfig（自己根据需要改）

package com.pdd.transports.config;import com.yiran.arch.leo.client.ConfigCache;
import io.kubernetes.client.ApiClient;
import io.kubernetes.client.apis.AppsV1Api;
import io.kubernetes.client.apis.CoreV1Api;
import io.kubernetes.client.apis.ExtensionsV1beta1Api;
import io.kubernetes.client.apis.RbacAuthorizationV1Api;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;import java.io.ByteArrayInputStream;
import java.io.InputStream;/*** @author jinhaozhi*/
@Slf4j
@Configuration
public class ApiClientConfig {// 直接使用eden-api的配置private static final String CONFIG_KEY = "eden-api.k8s.kube.config";private static final String CONFIG_DEBUG_KEY = "eden-api.k8s.debug.switch";@Value("${" + CONFIG_KEY + "}")private String config;@Value("${" + CONFIG_DEBUG_KEY + "}")private String debug;@Bean@Primarypublic ApiClient initK8sApiClient() {try {InputStream configStream = new ByteArrayInputStream(config.getBytes());final ApiClient apiClient = io.kubernetes.client.util.Config.fromConfig(configStream);apiClient.setDebugging(Boolean.valueOf(debug));io.kubernetes.client.Configuration.setDefaultApiClient(apiClient);ConfigCache.getInstance().addChange((key, value) -> {if (CONFIG_KEY.equals(key)) {log.warn("[ LEO ] Change k8s config, this change should have no effect.");} else if (CONFIG_DEBUG_KEY.equals(key)) {debug = value;apiClient.setDebugging(Boolean.valueOf(value));}

java客户端访问ApiServer(kubernetes-client使用)相关推荐

fastdfs java客户端_FastDFS的Java客户端访问
FastDFS的Java客户端访问: 没前奏,直接上车. 1. 引入依赖: net.oschina.zcx7878 fastdfs-client-java 1.27.0.0 2.在项目resource ...
Java客户端访问HBase集群解决方案(优化)
测试环境:Idea+Windows10 准备工作: <1>.打开本地 C:\Windows\System32\drivers\etc(系统默认)下名为hosts的系统文件,如果提示当前用户 ...
java客户端访问kafka
kafka版本:kafka_2.11-0.11.0.1.tgz centos7 关闭防火墙:systemctl stop firewalld.service 在kafka中配置文件: listener ...
redis外部客户端访问时 Redis Client On Error: Error: connect ETIMEDOUT Config right 端口问题导致
相同的帖子千篇一律,手打的内容万里挑一. 转载请标明出处. 今天突然遇到这个问题,看了好几个帖子没有解决掉我的问题. 检查方式: 1.出现问题是去看了服务器上的redis运行状态,运行状态都没问题(配 ...
【Java客户端访问Kafka】
我是
Java Socket编程系列（四）开发支持多客户端访问的Server
例子来自Java官方教程,稍作调整. 上一篇介绍了单客户端访问的Server实现,这一篇实现的是多个客户端请求服务端,根据服务端提示进行一系列操作. 协议类(和系列三一样没变): package co ...
java客户端带证书访问服务端_客户端与服务器SSL双向认证(客户端：java-服务端：java)...
客户端与服务器SSL双向认证(java-java):含源码 (一)实现技术: JSSE(Java Security Socket Extension) 是Sun为了解决在Internet上的实现安全信 ...
jms java client mq_将Java客户端（JMS）连接到IBM MQ时出现问题
我正在尝试使用基本上通过以下方式构建的Java客户端使用SSL消耗IBM MQ(版本8.0.0.8): Oracle JKD 8和IBM JRE 7(出于测试目的,我每个都有一个客户端) com.ib ...
Java判断用户是通过pc,还是安卓还是ios,还是微信客户端访问
在浏览器发送的请求中,请求头包含了客户端的信息, 其中微信客户端访问时候user-agent信息如下: Mozilla/5.0 (Linux; Android 5.0.1; M040 Build/LR ...

java客户端访问ApiServer(kubernetes-client使用)

前言

配置类ApiClientConfig（自己根据需要改）

java客户端访问ApiServer(kubernetes-client使用)相关推荐

最新文章

热门文章