Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
4f89ea27
S
SkyWalking
项目概览
apache
/
SkyWalking
上一次同步 大约 1 年
通知
302
Star
21345
Fork
6091
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
SkyWalking
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
4f89ea27
编写于
5月 28, 2019
作者:
G
Gao Hongtao
提交者:
wu-sheng
5月 28, 2019
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Filtering pods not in 'Running' phase (#2771)
* Filtering pods not in 'Running' phase * Amending checkstyle errors
上级
bcdf1c4b
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
8 addition
and
1 deletion
+8
-1
oap-server/server-receiver-plugin/envoy-metrics-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/envoy/als/K8sALSServiceMeshHTTPAnalysis.java
...ver/receiver/envoy/als/K8sALSServiceMeshHTTPAnalysis.java
+8
-1
未找到文件。
oap-server/server-receiver-plugin/envoy-metrics-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/envoy/als/K8sALSServiceMeshHTTPAnalysis.java
浏览文件 @
4f89ea27
...
@@ -63,6 +63,8 @@ public class K8sALSServiceMeshHTTPAnalysis implements ALSHTTPAnalysis {
...
@@ -63,6 +63,8 @@ public class K8sALSServiceMeshHTTPAnalysis implements ALSHTTPAnalysis {
private
static
final
String
ADDRESS_TYPE_INTERNAL_IP
=
"InternalIP"
;
private
static
final
String
ADDRESS_TYPE_INTERNAL_IP
=
"InternalIP"
;
private
static
final
String
VALID_PHASE
=
"Running"
;
@Getter
(
AccessLevel
.
PROTECTED
)
@Getter
(
AccessLevel
.
PROTECTED
)
private
final
AtomicReference
<
Map
<
String
,
ServiceMetaInfo
>>
ipServiceMap
=
new
AtomicReference
<>();
private
final
AtomicReference
<
Map
<
String
,
ServiceMetaInfo
>>
ipServiceMap
=
new
AtomicReference
<>();
...
@@ -93,8 +95,13 @@ public class K8sALSServiceMeshHTTPAnalysis implements ALSHTTPAnalysis {
...
@@ -93,8 +95,13 @@ public class K8sALSServiceMeshHTTPAnalysis implements ALSHTTPAnalysis {
Map
<
String
,
ServiceMetaInfo
>
ipMap
=
new
HashMap
<>(
list
.
getItems
().
size
());
Map
<
String
,
ServiceMetaInfo
>
ipMap
=
new
HashMap
<>(
list
.
getItems
().
size
());
long
startTime
=
System
.
nanoTime
();
long
startTime
=
System
.
nanoTime
();
for
(
V1Pod
item
:
list
.
getItems
())
{
for
(
V1Pod
item
:
list
.
getItems
())
{
if
(!
item
.
getStatus
().
getPhase
().
equals
(
VALID_PHASE
))
{
logger
.
debug
(
"Invalid pod {} is not in a valid phase {}"
,
item
.
getMetadata
().
getName
(),
item
.
getStatus
().
getPhase
());
continue
;
}
if
(
item
.
getStatus
().
getPodIP
().
equals
(
item
.
getStatus
().
getHostIP
()))
{
if
(
item
.
getStatus
().
getPodIP
().
equals
(
item
.
getStatus
().
getHostIP
()))
{
logger
.
warn
(
"Pod {}.{} is removed because hostIP and podIP are identical "
,
item
.
getMetadata
().
getName
());
logger
.
debug
(
"Pod {}.{} is removed because hostIP and podIP are identical "
,
item
.
getMetadata
().
getName
(),
item
.
getMetadata
().
getNamespace
());
continue
;
continue
;
}
}
ipMap
.
put
(
item
.
getStatus
().
getPodIP
(),
createServiceMetaInfo
(
item
.
getMetadata
()));
ipMap
.
put
(
item
.
getStatus
().
getPodIP
(),
createServiceMetaInfo
(
item
.
getMetadata
()));
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录