일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | ||
6 | 7 | 8 | 9 | 10 | 11 | 12 |
13 | 14 | 15 | 16 | 17 | 18 | 19 |
20 | 21 | 22 | 23 | 24 | 25 | 26 |
27 | 28 | 29 | 30 | 31 |
- 쿠키 하루
- mysql recovery
- 서버 재시작시 mount
- centos mount
- mysql galera cluster
- 쿠키 오늘
- docker 설치
- mysql all table truncate
- mysqlcheck
- elasticsearch mapping생성
- mysql database truncate
- mysql table 손상
- mysql 손상
- mysql auto repair
- mariadb 모든 데이터 삭제
- mysql DB권한
- galera cluster 재시작
- cookie 하루 저장
- mysql 자동복구
- mysql 사용자 생성
- mariadb galera cluster
- linux mount 방법
- cookie today
- mariadb all table truncate
- mysql database 검사
- mysql yum install
- mysql yum 설치
- mysql 모든 데이터 삭제
- mysql 검사
- 쿠키 하루 저장
- Today
- Total
IT
JAVA SPRING HTTP PATCH CALL 본문
쿠버네티스 deployment pod 갯수조정시 적용
PATCH method로만 가능해서 구글링하여 정리
logger.debug("=============kubernetesPodsSet==START=============");
Map<String, Object> result = new HashMap<String, Object>();
CloseableHttpClient httpClient = HttpClients.createDefault();
BufferedReader reader = null;
String url = "";
String deploymentName = "";
String Authorization = "";
try {
int poolCnt = Integer.parseInt((String) param.get("poolCnt"));
String poolSeq = (String) param.get("poolSeq");
List<EgovMap> kuberInfoList = monitorService.selectKubernetesCodeValue();
for (EgovMap tempMap : kuberInfoList) {
switch ((String) tempMap.get("code")) {
case "token":
Authorization = "Bearer " + (String) tempMap.get("codeValue");
break;
case "replicasUrl":
//여기서 default는 namespace명
url = https://192.168.217.128:6443/apis/apps/v1/namespaces/default/deployments/
break;
}
if (poolSeq.equals((String) tempMap.get("code"))) {
deploymentName = (String) tempMap.get("codeValue");
}
}
String data = "{\"spec\":{\"replicas\":" + poolCnt + "}}";
String contentType = "application/strategic-merge-patch+json";
url += deploymentName;
logger.debug("===deployment>" + deploymentName);
logger.debug("===poolCnt>" + poolCnt);
logger.debug("===data>" + data);
logger.debug("===Authorization>" + Authorization);
logger.debug("===url>" + url);
HttpPatch httpPatch = new HttpPatch(url);
httpPatch.setHeader("Content-Type", contentType);
httpPatch.setHeader("Authorization", Authorization);
StringEntity stringEntity = new StringEntity(data);
httpPatch.setEntity(stringEntity);
CloseableHttpResponse httpResponse;
httpResponse = httpClient.execute(httpPatch);
reader = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()));
String inputLine;
StringBuffer response = new StringBuffer();
while ((inputLine = reader.readLine()) != null) {
response.append(inputLine);
}
logger.debug(response.toString());
result.put("code", "00");
} catch (Exception e) {
e.printStackTrace();
result.put("code", "99");
result.put("msg", e.getMessage() == null ? e.toString() : e.getMessage());
} finally {
try {
reader.close();
httpClient.close();
} catch (Exception e) {
e.printStackTrace();
}
logger.debug("=============kubernetesPodsSet==END=============");
}
return result;
}