Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
eacc014e
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 搜索 >>
提交
eacc014e
编写于
2月 25, 2017
作者:
Z
zhangxin
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
update the comment to improve the comment readable
上级
ec857190
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
22 addition
and
21 deletion
+22
-21
skywalking-sniffer/skywalking-sdk-plugin/jedis-2.x-plugin/src/main/java/com/a/eye/skywalking/plugin/jedis/v2/JedisMethodInterceptor.java
...ye/skywalking/plugin/jedis/v2/JedisMethodInterceptor.java
+4
-5
skywalking-sniffer/skywalking-sdk-plugin/jedis-2.x-plugin/src/main/java/com/a/eye/skywalking/plugin/jedis/v2/define/JedisInstrumentation.java
...ywalking/plugin/jedis/v2/define/JedisInstrumentation.java
+2
-1
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/MotanConsumerFetchRequestURLInterceptor.java
...plugin/motan/MotanConsumerFetchRequestURLInterceptor.java
+2
-2
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/MotanConsumerInvokeInterceptor.java
...ywalking/plugin/motan/MotanConsumerInvokeInterceptor.java
+2
-2
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/MotanProviderInterceptor.java
...eye/skywalking/plugin/motan/MotanProviderInterceptor.java
+2
-2
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/define/MotanConsumerInstrumentation.java
...ing/plugin/motan/define/MotanConsumerInstrumentation.java
+6
-6
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/define/MotanProviderInstrumentation.java
...ing/plugin/motan/define/MotanProviderInstrumentation.java
+4
-3
未找到文件。
skywalking-sniffer/skywalking-sdk-plugin/jedis-2.x-plugin/src/main/java/com/a/eye/skywalking/plugin/jedis/v2/JedisMethodInterceptor.java
浏览文件 @
eacc014e
...
...
@@ -10,8 +10,9 @@ import com.a.eye.skywalking.trace.Span;
import
com.a.eye.skywalking.trace.tag.Tags
;
/**
* {@link JedisMethodInterceptor} create span and set redis host and redis connection information
* from {@link EnhancedClassInstanceContext#context} to span tags.
* {@link JedisMethodInterceptor} intercept all method of {@link redis.clients.jedis.Jedis}
* or {@link redis.clients.jedis.JedisCluster}. {@link JedisMethodInterceptor} record
* the redis host, operation name and the key of the operation.
*
* @author zhangxin
*/
...
...
@@ -36,9 +37,7 @@ public class JedisMethodInterceptor extends NoCocurrencyAceessObject {
* using {@link #KEY_OF_REDIS_HOST} is not null.
*/
protected
static
final
String
KEY_OF_REDIS_PORT
=
"KEY_OF_REDIS_PORT"
;
/**
* Redis component
*/
private
static
final
String
REDIS_COMPONENT
=
"Redis"
;
...
...
skywalking-sniffer/skywalking-sdk-plugin/jedis-2.x-plugin/src/main/java/com/a/eye/skywalking/plugin/jedis/v2/define/JedisInstrumentation.java
浏览文件 @
eacc014e
...
...
@@ -35,6 +35,7 @@ public class JedisInstrumentation extends ClassInstanceMethodsEnhancePluginDefin
private
static
final
String
CONSTRUCTOR_WITH_STRING_ARG_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.jedis.v2.JedisConstructorWithStringArgInterceptor"
;
private
static
final
String
CONSTRUCTOR_WITH_SHARD_INFO_ARG_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.jedis.v2.JedisConstructorWithShardInfoArgInterceptor"
;
private
static
final
String
CONSTRUCTOR_WITH_URI_ARG_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.jedis.v2.JedisConstructorWithUriArgInterceptor"
;
private
static
final
String
JEDIS_METHOD_INTERCET_CLASS
=
"com.a.eye.skywalking.plugin.jedis.v2.JedisMethodInterceptor"
;
@Override
public
String
enhanceClassName
()
{
...
...
@@ -94,7 +95,7 @@ public class JedisInstrumentation extends ClassInstanceMethodsEnhancePluginDefin
@Override
public
String
getMethodsInterceptor
()
{
return
"com.a.eye.skywalking.plugin.jedis.v2.JedisMethodInterceptor"
;
return
JEDIS_METHOD_INTERCET_CLASS
;
}
}};
}
...
...
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/ConsumerFetchRequestURLInterceptor.java
→
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/
Motan
ConsumerFetchRequestURLInterceptor.java
浏览文件 @
eacc014e
...
...
@@ -6,12 +6,12 @@ import com.a.eye.skywalking.api.plugin.interceptor.enhance.InstanceMethodsAround
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.MethodInterceptResult
;
/**
* {@link ConsumerFetchRequestURLInterceptor} record {@link com.weibo.api.motan.rpc.URL} to {@link EnhancedClassInstanceContext#context}
* {@link
Motan
ConsumerFetchRequestURLInterceptor} record {@link com.weibo.api.motan.rpc.URL} to {@link EnhancedClassInstanceContext#context}
* for the operation name that create span need.
*
* @author zhangxin
*/
public
class
ConsumerFetchRequestURLInterceptor
implements
InstanceMethodsAroundInterceptor
{
public
class
Motan
ConsumerFetchRequestURLInterceptor
implements
InstanceMethodsAroundInterceptor
{
private
static
final
String
CONTEXT_NAME_OF_REQUEST_URL
=
"REQUEST_URL"
;
...
...
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/ConsumerInvokeInterceptor.java
→
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/
Motan
ConsumerInvokeInterceptor.java
浏览文件 @
eacc014e
...
...
@@ -13,13 +13,13 @@ import com.weibo.api.motan.rpc.Response;
import
com.weibo.api.motan.rpc.URL
;
/**
* {@link ConsumerInvokeInterceptor} create span by fetch request url from
* {@link
Motan
ConsumerInvokeInterceptor} create span by fetch request url from
* {@link EnhancedClassInstanceContext#context} and transport serialized context
* data to provider side through {@link Request#setAttachment(String, String)}.
*
* @author zhangxin
*/
public
class
ConsumerInvokeInterceptor
implements
InstanceMethodsAroundInterceptor
{
public
class
Motan
ConsumerInvokeInterceptor
implements
InstanceMethodsAroundInterceptor
{
/**
* Context name of request url in {@link EnhancedClassInstanceContext#context}.
...
...
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/ProviderInterceptor.java
→
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/
Motan
ProviderInterceptor.java
浏览文件 @
eacc014e
...
...
@@ -18,12 +18,12 @@ import com.weibo.api.motan.rpc.URL;
* Current trace segment will ref the trace segment from previous level if the serialized context data that fetch
* from {@link Request#getAttachments()} is not null.
*
* {@link ProviderInterceptor} intercept all constructor of {@link com.weibo.api.motan.rpc.AbstractProvider} for record
* {@link
Motan
ProviderInterceptor} intercept all constructor of {@link com.weibo.api.motan.rpc.AbstractProvider} for record
* the request url from consumer side.
*
* @author zhangxin
*/
public
class
ProviderInterceptor
implements
InstanceConstructorInterceptor
,
InstanceMethodsAroundInterceptor
{
public
class
Motan
ProviderInterceptor
implements
InstanceConstructorInterceptor
,
InstanceMethodsAroundInterceptor
{
/**
* The
...
...
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/define/MotanConsumerInstrumentation.java
浏览文件 @
eacc014e
...
...
@@ -3,8 +3,8 @@ package com.a.eye.skywalking.plugin.motan.define;
import
com.a.eye.skywalking.api.plugin.interceptor.ConstructorInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.InstanceMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine
;
import
com.a.eye.skywalking.plugin.motan.ConsumerFetchRequestURLInterceptor
;
import
com.a.eye.skywalking.plugin.motan.ConsumerInvokeInterceptor
;
import
com.a.eye.skywalking.plugin.motan.
Motan
ConsumerFetchRequestURLInterceptor
;
import
com.a.eye.skywalking.plugin.motan.
Motan
ConsumerInvokeInterceptor
;
import
com.weibo.api.motan.rpc.Request
;
import
com.weibo.api.motan.rpc.URL
;
...
...
@@ -15,9 +15,9 @@ import static net.bytebuddy.matcher.ElementMatchers.named;
/**
* {@link MotanConsumerInstrumentation} presents that skywalking intercept
* {@link com.weibo.api.motan.cluster.support.ClusterSpi#call(Request)} by using {@link ConsumerInvokeInterceptor} and
* {@link com.weibo.api.motan.cluster.support.ClusterSpi#call(Request)} by using {@link
Motan
ConsumerInvokeInterceptor} and
* intercept {@link com.weibo.api.motan.cluster.support.ClusterSpi#setUrl(URL)} by using
* {@link
ConsumerFetchRequestURLInterceptor} to intercept{@link
ConsumerFetchRequestURLInterceptor}.
* {@link
MotanConsumerFetchRequestURLInterceptor} to intercept{@link Motan
ConsumerFetchRequestURLInterceptor}.
*
* @author zhangxin
*/
...
...
@@ -25,9 +25,9 @@ public class MotanConsumerInstrumentation extends ClassInstanceMethodsEnhancePlu
private
static
final
String
ENHANCE_CLASS
=
"com.weibo.api.motan.cluster.support.ClusterSpi"
;
private
static
final
String
FETCH_REQUEST_URL_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.ConsumerFetchRequestURLInterceptor"
;
private
static
final
String
FETCH_REQUEST_URL_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.
Motan
ConsumerFetchRequestURLInterceptor"
;
private
static
final
String
INVOKE_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.ConsumerInvokeInterceptor"
;
private
static
final
String
INVOKE_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.
Motan
ConsumerInvokeInterceptor"
;
@Override
protected
String
enhanceClassName
()
{
...
...
skywalking-sniffer/skywalking-sdk-plugin/motan-plugin/src/main/java/com/a/eye/skywalking/plugin/motan/define/MotanProviderInstrumentation.java
浏览文件 @
eacc014e
...
...
@@ -3,6 +3,7 @@ package com.a.eye.skywalking.plugin.motan.define;
import
com.a.eye.skywalking.api.plugin.interceptor.ConstructorInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.InstanceMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine
;
import
com.a.eye.skywalking.plugin.motan.MotanProviderInterceptor
;
import
com.weibo.api.motan.rpc.Request
;
import
net.bytebuddy.description.method.MethodDescription
;
...
...
@@ -13,7 +14,7 @@ import static net.bytebuddy.matcher.ElementMatchers.named;
/**
* {@link MotanProviderInstrumentation} presents that skywalking will use
* {@link
com.a.eye.skywalking.plugin.motan.
ProviderInterceptor} to intercept
* {@link
Motan
ProviderInterceptor} to intercept
* all constructor of {@link com.weibo.api.motan.rpc.AbstractProvider} and
* {@link com.weibo.api.motan.rpc.AbstractProvider#call(Request)}.
*
...
...
@@ -28,11 +29,11 @@ public class MotanProviderInstrumentation extends ClassInstanceMethodsEnhancePlu
/**
* Class that intercept all constructor of ${@link com.weibo.api.motan.rpc.AbstractProvider}.
*/
private
static
final
String
CONSTRUCTOR_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.ProviderInterceptor"
;
private
static
final
String
CONSTRUCTOR_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.
Motan
ProviderInterceptor"
;
/**
* Class that intercept {@link com.weibo.api.motan.rpc.AbstractProvider#call(Request)}.
*/
private
static
final
String
PROVIDER_INVOKE_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.ProviderInterceptor"
;
private
static
final
String
PROVIDER_INVOKE_INTERCEPT_CLASS
=
"com.a.eye.skywalking.plugin.motan.
Motan
ProviderInterceptor"
;
@Override
protected
String
enhanceClassName
()
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录