57 lines
1.9 KiB
Java
57 lines
1.9 KiB
Java
package com.educoder.bridge.controller;
|
||
|
||
import com.alibaba.fastjson.JSONObject;
|
||
import com.educoder.bridge.service.K8sService;
|
||
import io.fabric8.kubernetes.client.KubernetesClient;
|
||
import io.swagger.annotations.Api;
|
||
import io.swagger.annotations.ApiOperation;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.http.MediaType;
|
||
import org.springframework.web.bind.annotation.RequestMapping;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.web.bind.annotation.RestController;
|
||
|
||
import java.util.List;
|
||
|
||
/**
|
||
* Created by liqiankun on 2017/11/16 0016
|
||
* Description：
|
||
*/
|
||
@Api(value = "资源监控", hidden = true)
|
||
@RestController
|
||
@RequestMapping("/monitor")
|
||
public class MonitorController {
|
||
Logger logger = LoggerFactory.getLogger(MonitorController.class);
|
||
@Autowired
|
||
private K8sService k8sService;
|
||
|
||
/**
|
||
* 简单地获取集群中的Pod总量及各个节点上的Pod分布
|
||
*
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(path = "/getPodsInfo")
|
||
@ApiOperation(value = "获取集群中某个节点的信息", httpMethod = "POST", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
||
public JSONObject podsInfo() throws Exception {
|
||
int podSum = k8sService.getPodSum();
|
||
List<String> nodeIP = k8sService.getNodesIP();
|
||
//生成Json格式的返回结果
|
||
StringBuffer jsonResult = new StringBuffer("[");
|
||
for (String ip : nodeIP) {
|
||
int num = k8sService.getPodNum(ip);
|
||
jsonResult.append("{\"ip\":" + "\"" + ip + "\"," + "\"num\":" + "\"" + num + "\"},");
|
||
}
|
||
int length = jsonResult.length() - 1;
|
||
jsonResult.deleteCharAt(length);
|
||
jsonResult.append("]");
|
||
|
||
JSONObject response = new JSONObject();
|
||
response.put("sum", podSum);
|
||
response.put("distr", jsonResult);
|
||
response.put("code", 0);
|
||
return response;
|
||
}
|
||
}
|