Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
H
holmes
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
QA
holmes
Commits
7372dcc0
Commit
7372dcc0
authored
May 27, 2022
by
黎博
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
/dubbo/port里加点日志
parent
8a8219e8
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
5 additions
and
2 deletions
+5
-2
K8sController.java
src/main/java/cn/qg/holmes/controller/k8s/K8sController.java
+5
-2
No files found.
src/main/java/cn/qg/holmes/controller/k8s/K8sController.java
View file @
7372dcc0
...
@@ -124,7 +124,7 @@ public class K8sController {
...
@@ -124,7 +124,7 @@ public class K8sController {
// 新增Service
// 新增Service
Service
service
=
tkeService
.
createServiceByYaml
(
serviceCreateVo
);
Service
service
=
tkeService
.
createServiceByYaml
(
serviceCreateVo
);
// 休眠3秒,防止创建服务的时候获取不到Service暴露的端口
// 休眠3秒,防止创建服务的时候获取不到Service暴露的端口
Thread
.
sleep
(
5
000
);
Thread
.
sleep
(
3
000
);
log
.
info
(
"/service/create创建Deployment前,Service状态:{}"
,
YamlUtils
.
JsonToYamlStr
(
JSON
.
toJSONString
(
service
)));
log
.
info
(
"/service/create创建Deployment前,Service状态:{}"
,
YamlUtils
.
JsonToYamlStr
(
JSON
.
toJSONString
(
service
)));
// 新增Deployment
// 新增Deployment
tkeService
.
createDeploymentByYaml
(
serviceCreateVo
);
tkeService
.
createDeploymentByYaml
(
serviceCreateVo
);
...
@@ -512,7 +512,10 @@ public class K8sController {
...
@@ -512,7 +512,10 @@ public class K8sController {
@RequestParam
String
serviceType
,
@RequestParam
String
serviceType
,
@RequestParam
String
serviceName
,
@RequestParam
String
serviceName
,
@RequestParam
String
key
)
{
@RequestParam
String
key
)
{
List
<
ServicePort
>
servicePortList
=
tkeService
.
getServiceDetail
(
namespace
,
serviceName
).
getSpec
().
getPorts
();
log
.
info
(
"开始调取/k8s/dubbo/port接口,namespace:{}, serviceName: {}, key: {}"
,
namespace
,
serviceName
,
key
);
Service
service
=
tkeService
.
getServiceDetail
(
namespace
,
serviceName
);
log
.
info
(
"获取到的Service信息:{}"
,
JSON
.
toJSONString
(
service
));
List
<
ServicePort
>
servicePortList
=
service
.
getSpec
().
getPorts
();
Map
<
String
,
Object
>
serviceMap
=
new
HashMap
<>();
Map
<
String
,
Object
>
serviceMap
=
new
HashMap
<>();
List
<
Map
<
String
,
Object
>>
portMappingList
=
new
ArrayList
<>();
List
<
Map
<
String
,
Object
>>
portMappingList
=
new
ArrayList
<>();
if
(
servicePortList
.
size
()
>
0
)
{
if
(
servicePortList
.
size
()
>
0
)
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment