Skip to content

S
SkyWalking

润土的好友猹 / SkyWalking
与 Fork 源项目一致

Fork自 apache / SkyWalking

通知 9
Star 0
Fork 0
S
SkyWalking

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 944160d2 编写于 作者: A ascrutae
浏览文件
操作

修改包名和修复bug

上级 c9b6eade
展开全部 隐藏空白更改
内联 并排
Showing with 1765 addition and 3563 deletion
HOW_TO_FIND_TID.md
浏览文件 @ 944160d2
......@@ -11,7 +11,7 @@
```
- 配置log4j配置文件
```properties
log4j.appender.A1.layout=com.ai.cloud.skywalking.plugin.log.log4j.v1.x.TraceIdPatternLayout
log4j.appender.A1.layout=TraceIdPatternLayout
#%x为traceid的转义符
log4j.appender.A1.layout.ConversionPattern=[%x] %-d{yyyy-MM-dd HH:mm:ss.SSS} %c %n[%p] %n%m%n
```
......
pom.xml
浏览文件 @ 944160d2
......@@ -3,7 +3,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking</artifactId>
<version>1.0-Final</version>
<modules>
......@@ -33,7 +33,7 @@
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-protocol</artifactId>
<version>1.0-Final</version>
</dependency>
......@@ -64,7 +64,7 @@
<repository>
<id>bintray-wu-sheng-sky-walking-repository</id>
<name>wu-sheng-sky-walking-repository</name>
<url>https://api.bintray.com/maven/wu-sheng/skywalking/com.ai.cloud.skywalking/;publish=1</url>
<url>https://api.bintray.com/maven/wu-sheng/skywalking/com.a.eye.skywalking/;publish=1</url>
</repository>
</distributionManagement>
</project>
samples/skywalking-auth/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-auth</artifactId>
<version>1.0-Final</version>
<packaging>jar</packaging>
......
samples/skywalking-auth/src/main/resources/sky-walking.auth
浏览文件 @ 944160d2
#skyWalking用户ID
skywalking.user_id=123
skywalking.user_id=18
#skyWalking应用编码
skywalking.application_code=skywalking-sample-dubbo
skywalking.application_code=meet-web
#skywalking auth的环境变量名字
skywalking.auth_system_env_name=SKYWALKING_RUN
#skywalking数据编码
......
samples/skywalking-example/example-dubbo/dubbo-impl/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>example-dubbo</artifactId>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<version>1.0-Final</version>
</parent>
<modelVersion>4.0.0</modelVersion>
......@@ -19,14 +19,20 @@
<dependencies>
<dependency>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>dubbo-interfaces</artifactId>
<version>1.0-Final</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbox</artifactId>
<version>2.8.4</version>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.javassist</groupId>
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/dubbo/impl/SampleDubboInterfaceImpl.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/dubbo/impl/SampleDubboInterfaceImpl.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.dubbo.impl;
package com.a.eye.skywalking.sample.dubbo.impl;
import com.ai.cloud.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import com.ai.cloud.skywalking.sample.service.inter.SampleServiceInterface;
import com.a.eye.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import com.a.eye.skywalking.sample.service.inter.SampleServiceInterface;
import com.alibaba.dubbo.config.annotation.Service;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/dao/Sampletable1Mapper.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/dao/Sampletable1Mapper.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.dao;
package com.a.eye.skywalking.sample.mybatis.dao;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1Example;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable1;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable1Example;
import org.apache.ibatis.annotations.Param;
import java.util.List;
......@@ -95,4 +95,4 @@ public interface Sampletable1Mapper {
* @mbggenerated Sun Jul 24 09:19:30 CST 2016
*/
int updateByPrimaryKey(Sampletable1 record);
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/dao/Sampletable2Mapper.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/dao/Sampletable2Mapper.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.dao;
package com.a.eye.skywalking.sample.mybatis.dao;
import java.util.List;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2Example;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable2;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable2Example;
import org.apache.ibatis.annotations.Param;
public interface Sampletable2Mapper {
......@@ -95,4 +95,4 @@ public interface Sampletable2Mapper {
* @mbggenerated Sun Jul 24 09:26:38 CST 2016
*/
int updateByPrimaryKey(Sampletable2 record);
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/model/Sampletable1.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/model/Sampletable1.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.model;
package com.a.eye.skywalking.sample.mybatis.model;
public class Sampletable1 {
/**
......@@ -60,4 +60,4 @@ public class Sampletable1 {
public void setValue1(String value1) {
this.value1 = value1 == null ? null : value1.trim();
}
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/model/Sampletable1Example.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/model/Sampletable1Example.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.model;
package com.a.eye.skywalking.sample.mybatis.model;
import java.util.ArrayList;
import java.util.List;
......@@ -439,4 +439,4 @@ public class Sampletable1Example {
this(condition, value, secondValue, null);
}
}
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/model/Sampletable2.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/model/Sampletable2.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.model;
package com.a.eye.skywalking.sample.mybatis.model;
public class Sampletable2 {
/**
......@@ -66,4 +66,4 @@ public class Sampletable2 {
public void setValue2(String value2) {
this.value2 = value2 == null ? null : value2.trim();
}
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/mybatis/model/Sampletable2Example.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/mybatis/model/Sampletable2Example.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.mybatis.model;
package com.a.eye.skywalking.sample.mybatis.model;
import java.util.ArrayList;
......@@ -440,4 +440,4 @@ public class Sampletable2Example {
this(condition, value, secondValue, null);
}
}
}
\ No newline at end of file
}
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/service/impl/SampleServiceImpl.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/service/impl/SampleServiceImpl.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.service.impl;
package com.a.eye.skywalking.sample.service.impl;
import com.ai.cloud.skywalking.sample.mybatis.dao.Sampletable1Mapper;
import com.ai.cloud.skywalking.sample.mybatis.dao.Sampletable2Mapper;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1;
import com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2;
import com.ai.cloud.skywalking.sample.service.inter.SampleServiceInterface;
import com.a.eye.skywalking.sample.mybatis.dao.Sampletable2Mapper;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable1;
import com.a.eye.skywalking.sample.mybatis.dao.Sampletable1Mapper;
import com.a.eye.skywalking.sample.mybatis.model.Sampletable2;
import com.a.eye.skywalking.sample.service.inter.SampleServiceInterface;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/ai/cloud/skywalking/sample/util/DubboStart.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/main/java/com/a/eye/skywalking/sample/util/DubboStart.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.util;
package com.a.eye.skywalking.sample.util;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/resources/mybatis/Sampletable1Mapper.xml
浏览文件 @ 944160d2
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ai.cloud.skywalking.sample.mybatis.dao.Sampletable1Mapper">
<resultMap id="BaseResultMap" type="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1">
<mapper namespace="com.a.eye.skywalking.sample.mybatis.dao.Sampletable1Mapper">
<resultMap id="BaseResultMap" type="com.a.eye.skywalking.sample.mybatis.model.Sampletable1">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -86,7 +86,7 @@
-->
KEY1, VALUE1
</sql>
<select id="selectByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1Example" resultMap="BaseResultMap">
<select id="selectByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1Example" resultMap="BaseResultMap">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -125,7 +125,7 @@
delete from PUBLIC.SAMPLETABLE1
where KEY1 = #{key1,jdbcType=VARCHAR}
</delete>
<delete id="deleteByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1Example">
<delete id="deleteByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1Example">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -136,7 +136,7 @@
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1">
<insert id="insert" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -145,7 +145,7 @@
insert into PUBLIC.SAMPLETABLE1 (KEY1, VALUE1)
values (#{key1,jdbcType=VARCHAR}, #{value1,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1">
<insert id="insertSelective" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -169,7 +169,7 @@
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1Example" resultType="java.lang.Integer">
<select id="countByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1Example" resultType="java.lang.Integer">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -212,7 +212,7 @@
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1">
<update id="updateByPrimaryKeySelective" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -226,7 +226,7 @@
</set>
where KEY1 = #{key1,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable1">
<update id="updateByPrimaryKey" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable1">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -236,4 +236,4 @@
set VALUE1 = #{value1,jdbcType=VARCHAR}
where KEY1 = #{key1,jdbcType=VARCHAR}
</update>
</mapper>
\ No newline at end of file
</mapper>
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/resources/mybatis/Sampletable2Mapper.xml
浏览文件 @ 944160d2
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ai.cloud.skywalking.sample.mybatis.dao.Sampletable2Mapper">
<resultMap id="BaseResultMap" type="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2">
<mapper namespace="com.a.eye.skywalking.sample.mybatis.dao.Sampletable2Mapper">
<resultMap id="BaseResultMap" type="com.a.eye.skywalking.sample.mybatis.model.Sampletable2">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -86,7 +86,7 @@
-->
KEY2, VALUE2
</sql>
<select id="selectByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2Example" resultMap="BaseResultMap">
<select id="selectByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2Example" resultMap="BaseResultMap">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -125,7 +125,7 @@
delete from PUBLIC.SAMPLETABLE2
where KEY2 = #{key2,jdbcType=VARCHAR}
</delete>
<delete id="deleteByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2Example">
<delete id="deleteByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2Example">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -136,7 +136,7 @@
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2">
<insert id="insert" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -145,7 +145,7 @@
insert into PUBLIC.SAMPLETABLE2 (KEY2, VALUE2)
values (#{key2,jdbcType=VARCHAR}, #{value2,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2">
<insert id="insertSelective" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -169,7 +169,7 @@
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2Example" resultType="java.lang.Integer">
<select id="countByExample" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2Example" resultType="java.lang.Integer">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -212,7 +212,7 @@
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2">
<update id="updateByPrimaryKeySelective" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -226,7 +226,7 @@
</set>
where KEY2 = #{key2,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.ai.cloud.skywalking.sample.mybatis.model.Sampletable2">
<update id="updateByPrimaryKey" parameterType="com.a.eye.skywalking.sample.mybatis.model.Sampletable2">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.
......@@ -236,4 +236,4 @@
set VALUE2 = #{value2,jdbcType=VARCHAR}
where KEY2 = #{key2,jdbcType=VARCHAR}
</update>
</mapper>
\ No newline at end of file
</mapper>
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/resources/provider/dubbo-provider.xml
浏览文件 @ 944160d2
......@@ -10,6 +10,6 @@
<dubbo:application name="skywalking-sample-dubbo-impl" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" timeout="50000" />
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:annotation package="com.ai.cloud.skywalking.sample.dubbo"/>
<dubbo:annotation package="com.a.eye.skywalking.sample.dubbo"/>
</beans>
samples/skywalking-example/example-dubbo/dubbo-impl/src/main/resources/spring-context.xml
浏览文件 @ 944160d2
......@@ -7,7 +7,7 @@
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd">
<!-- 自动扫描 -->
<context:component-scan base-package="com.ai.cloud.skywalking.sample"/>
<context:component-scan base-package="com.a.eye.skywalking.sample"/>
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
......@@ -16,7 +16,7 @@
</bean>
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.ai.cloud.skywalking.sample.mybatis"/>
<property name="basePackage" value="com.a.eye.skywalking.sample.mybatis"/>
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
</bean>
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/test/java/com/ai/cloud/skywalking/sample/dubbo/impl/SampleDubboInterfaceImplTest.java → samples/skywalking-example/example-dubbo/dubbo-impl/src/test/java/com/a/eye/skywalking/sample/dubbo/impl/SampleDubboInterfaceImplTest.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.dubbo.impl;
package com.a.eye.skywalking.sample.dubbo.impl;
import com.ai.cloud.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import com.a.eye.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
......
samples/skywalking-example/example-dubbo/dubbo-impl/src/test/resources/consumer/dubbo-consumer.xml
浏览文件 @ 944160d2
......@@ -7,6 +7,6 @@
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="skywalking-sample-dubbo-consumer"/>
<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
<dubbo:reference id="sampleDubboInterface" interface="com.ai.cloud.skywalking.sample.dubbo.interfaces.SampleDubboInterface"/>
</beans>
\ No newline at end of file
<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" timeout="500000"/>
<dubbo:reference id="sampleDubboInterface" interface="com.a.eye.skywalking.sample.dubbo.interfaces.SampleDubboInterface"/>
</beans>
samples/skywalking-example/example-dubbo/dubbo-interfaces/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>example-dubbo</artifactId>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<version>1.0-Final</version>
</parent>
<modelVersion>4.0.0</modelVersion>
......
samples/skywalking-example/example-dubbo/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>skywalking-example</artifactId>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<version>1.0-Final</version>
</parent>
<modelVersion>4.0.0</modelVersion>
......
samples/skywalking-example/example-dubbox-rest/pom.xml
浏览文件 @ 944160d2
......@@ -4,7 +4,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>skywalking-example</artifactId>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<version>1.0-Final</version>
</parent>
<modelVersion>4.0.0</modelVersion>
......
samples/skywalking-example/example-dubbox-rest/src/main/java/com/ai/cloud/skywalking/sample/dubboxrest/DubboxRestConsumer.java → samples/skywalking-example/example-dubbox-rest/src/main/java/com/a/eye/skywalking/sample/dubboxrest/DubboxRestConsumer.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.dubboxrest;
package com.a.eye.skywalking.sample.dubboxrest;
import com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA;
import com.ai.cloud.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA;
import com.a.eye.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
......
samples/skywalking-example/example-dubbox-rest/src/main/java/com/ai/cloud/skywalking/sample/dubboxrest/impl/DubboxRestInterAImpl.java → samples/skywalking-example/example-dubbox-rest/src/main/java/com/a/eye/skywalking/sample/dubboxrest/impl/DubboxRestInterAImpl.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.dubboxrest.impl;
package com.a.eye.skywalking.sample.dubboxrest.impl;
import com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA;
import com.ai.cloud.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA;
import com.a.eye.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Autowired;
......
samples/skywalking-example/example-dubbox-rest/src/main/java/com/ai/cloud/skywalking/sample/dubboxrest/interfaces/IDubboxRestInterA.java → samples/skywalking-example/example-dubbox-rest/src/main/java/com/a/eye/skywalking/sample/dubboxrest/interfaces/IDubboxRestInterA.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.dubboxrest.interfaces;
package com.a.eye.skywalking.sample.dubboxrest.interfaces;
import com.ai.cloud.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import com.a.eye.skywalking.sample.dubboxrest.interfaces.param.DubboxRestInterAParameter;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
......
samples/skywalking-example/example-dubbox-rest/src/main/resources/consumer/dubbox-rest-consumer.xml
浏览文件 @ 944160d2
......@@ -8,7 +8,7 @@
<dubbo:application name="skywalking-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:reference id="dubboxRestInterA"
interface="com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
interface="com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
url="rest://127.0.0.1:20880"/>
</beans>
samples/skywalking-example/example-dubbox-rest/src/main/resources/provider/dubbox-rest-provider.xml
浏览文件 @ 944160d2
......@@ -8,8 +8,8 @@
<dubbo:application name="skywalking-dubbo-rest-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="rest" port="20880" server="tomcat"/>
<bean id="dubboxRestInterA" class="com.ai.cloud.skywalking.sample.dubboxrest.impl.DubboxRestInterAImpl"/>
<dubbo:service interface="com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
<bean id="dubboxRestInterA" class="com.a.eye.skywalking.sample.dubboxrest.impl.DubboxRestInterAImpl"/>
<dubbo:service interface="com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
ref="dubboxRestInterA"/>
</beans>
samples/skywalking-example/example-dubbox-rest/target/agent/sky-walking.auth 已删除 100644 → 0
浏览文件 @ c9b6eade
#skyWalking用户ID
skywalking.user_id=123
#skyWalking应用编码
skywalking.application_code=skywalking-sample-dubbo
#skywalking auth的环境变量名字
skywalking.auth_system_env_name=SKYWALKING_RUN
#skywalking数据编码
skywalking.charset=UTF-8
skywalking.auth_override=true
#是否使用STD替换日志输出
skywalking.logger_std_out_override=false;
#是否打印数据
buriedpoint.printf=true
#埋点异常的最大长度
buriedpoint.max_exception_stack_length=4000
#业务字段的最大长度
buriedpoint.businesskey_max_length=300
#过滤异常
buriedpoint.exclusive_exceptions=java.lang.RuntimeException
#最大发送者的连接数阀比例
sender.connect_percent=100
#发送服务端配置
sender.servers_addr=127.0.0.1:34000
#最大发送的副本数量
sender.max_copy_num=2
#发送的最大长度
sender.max_send_length=20000
#当没有Sender时,尝试获取sender的等待周期
sender.retry_get_sender_wait_interval=2000
#最大消费线程数
consumer.max_consumer=1
#消费者最大等待时间
consumer.max_wait_time=5
#发送失败等待时间
consumer.consumer_fail_retry_wait_interval=50
#每个Buffer的最大个数
buffer.buffer_max_size=18000
#Buffer池的最大长度
buffer.pool_size=5
#发送检查线程检查周期
senderchecker.check_polling_time=200
samples/skywalking-example/example-dubbox-rest/target/classes/consumer/dubbox-rest-consumer.xml
浏览文件 @ 944160d2
......@@ -8,7 +8,7 @@
<dubbo:application name="skywalking-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:reference id="dubboxRestInterA"
interface="com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
interface="com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
url="rest://127.0.0.1:20880"/>
</beans>
samples/skywalking-example/example-dubbox-rest/target/classes/provider/dubbox-rest-provider.xml
浏览文件 @ 944160d2
......@@ -8,8 +8,8 @@
<dubbo:application name="skywalking-dubbo-rest-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="rest" port="20880" server="tomcat"/>
<bean id="dubboxRestInterA" class="com.ai.cloud.skywalking.sample.dubboxrest.impl.DubboxRestInterAImpl"/>
<dubbo:service interface="com.ai.cloud.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
<bean id="dubboxRestInterA" class="com.a.eye.skywalking.sample.dubboxrest.impl.DubboxRestInterAImpl"/>
<dubbo:service interface="com.a.eye.skywalking.sample.dubboxrest.interfaces.IDubboxRestInterA"
ref="dubboxRestInterA"/>
</beans>
samples/skywalking-example/example-web/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<parent>
<artifactId>skywalking-example</artifactId>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<version>1.0-Final</version>
</parent>
<modelVersion>4.0.0</modelVersion>
......@@ -47,7 +47,7 @@
<version>3.1.0</version>
</dependency>
<dependency>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>dubbo-interfaces</artifactId>
<version>1.0-Final</version>
</dependency>
......
samples/skywalking-example/example-web/src/main/java/com/ai/cloud/skywalking/sample/web/controller/SampleWebController.java → samples/skywalking-example/example-web/src/main/java/com/a/eye/skywalking/sample/web/controller/SampleWebController.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.sample.web.controller;
package com.a.eye.skywalking.sample.web.controller;
import com.ai.cloud.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import com.a.eye.skywalking.sample.dubbo.interfaces.SampleDubboInterface;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
......
samples/skywalking-example/example-web/src/main/resources/consumer/dubbo-consumer.xml
浏览文件 @ 944160d2
......@@ -8,5 +8,5 @@
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="skywalking-sample-dubbo-consumer"/>
<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" timeout="50000"/>
<dubbo:reference id="sampleDubboInterface" interface="com.ai.cloud.skywalking.sample.dubbo.interfaces.SampleDubboInterface"/>
<dubbo:reference id="sampleDubboInterface" interface="com.a.eye.skywalking.sample.dubbo.interfaces.SampleDubboInterface"/>
</beans>
samples/skywalking-example/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-example</artifactId>
<version>1.0-Final</version>
......
skywalking-alarm/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-alarm</artifactId>
<version>1.0-Final</version>
<packaging>jar</packaging>
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmMessageProcessThread.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmMessageProcessThread.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.AlarmMessageDao;
import com.ai.cloud.skywalking.alarm.model.AlarmRule;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadStatus;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadValue;
import com.ai.cloud.skywalking.alarm.model.UserInfo;
import com.ai.cloud.skywalking.alarm.procesor.AlarmMessageProcessor;
import com.ai.cloud.skywalking.alarm.util.ProcessUtil;
import com.ai.cloud.skywalking.alarm.util.ZKUtil;
package com.a.eye.skywalking.alarm;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.dao.AlarmMessageDao;
import com.a.eye.skywalking.alarm.model.AlarmRule;
import com.a.eye.skywalking.alarm.model.ProcessThreadStatus;
import com.a.eye.skywalking.alarm.model.ProcessThreadValue;
import com.a.eye.skywalking.alarm.procesor.AlarmMessageProcessor;
import com.a.eye.skywalking.alarm.util.ZKUtil;
import com.a.eye.skywalking.alarm.model.UserInfo;
import com.a.eye.skywalking.alarm.util.ProcessUtil;
import com.google.gson.Gson;
import org.apache.curator.framework.api.CuratorWatcher;
import org.apache.logging.log4j.LogManager;
......@@ -27,12 +27,12 @@ public class AlarmMessageProcessThread extends Thread {
private Logger logger = LogManager.getLogger(AlarmMessageProcessThread.class);
private String threadId;
private String threadId;
private ProcessThreadStatus status;
private List<String> processUserIds;
private CoordinatorStatusWatcher watcher = new CoordinatorStatusWatcher();
private Map<UserInfo, List<AlarmRule>> cacheRules = new HashMap<UserInfo, List<AlarmRule>>();
private static AlarmMessageProcessor processor = new AlarmMessageProcessor();
private List<String> processUserIds;
private CoordinatorStatusWatcher watcher = new CoordinatorStatusWatcher();
private Map<UserInfo, List<AlarmRule>> cacheRules = new HashMap<UserInfo, List<AlarmRule>>();
private static AlarmMessageProcessor processor = new AlarmMessageProcessor();
public AlarmMessageProcessThread() {
// 初始化生成ThreadId
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/AlarmProcessServer.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmProcessServer.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm;
package com.a.eye.skywalking.alarm;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.conf.ConfigInitializer;
import com.ai.cloud.skywalking.alarm.util.ZKUtil;
import com.a.eye.skywalking.alarm.conf.ConfigInitializer;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.util.ZKUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UserInfoCoordinator.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.AlarmMessageDao;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadStatus;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadValue;
import com.ai.cloud.skywalking.alarm.util.ProcessUtil;
import com.ai.cloud.skywalking.alarm.util.ZKUtil;
package com.a.eye.skywalking.alarm;
import com.a.eye.skywalking.alarm.dao.AlarmMessageDao;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.model.ProcessThreadStatus;
import com.a.eye.skywalking.alarm.model.ProcessThreadValue;
import com.a.eye.skywalking.alarm.util.ProcessUtil;
import com.a.eye.skywalking.alarm.util.ZKUtil;
import com.google.gson.Gson;
import org.apache.curator.framework.api.CuratorWatcher;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UsersChangedDetectionThread.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UsersChangedDetectionThread.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm;
package com.a.eye.skywalking.alarm;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.AlarmMessageDao;
import com.ai.cloud.skywalking.alarm.util.MD5Encryption;
import com.ai.cloud.skywalking.alarm.util.ZKUtil;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.dao.AlarmMessageDao;
import com.a.eye.skywalking.alarm.util.MD5Encryption;
import com.a.eye.skywalking.alarm.util.ZKUtil;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/conf/Config.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/conf/Config.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.conf;
package com.a.eye.skywalking.alarm.conf;
public class Config {
......@@ -94,4 +94,4 @@ public class Config {
public static class TemplateInfo {
public static String CONFIG_ID = "1001";
}
}
\ No newline at end of file
}
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/conf/ConfigInitializer.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/conf/ConfigInitializer.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.conf;
package com.a.eye.skywalking.alarm.conf;
import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/AlarmMessageDao.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/dao/AlarmMessageDao.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.dao;
package com.a.eye.skywalking.alarm.dao;
import com.ai.cloud.skywalking.alarm.model.AlarmRule;
import com.ai.cloud.skywalking.alarm.model.ApplicationInfo;
import com.ai.cloud.skywalking.alarm.model.UserInfo;
import com.ai.cloud.skywalking.alarm.util.DBConnectUtil;
import com.a.eye.skywalking.alarm.model.AlarmRule;
import com.a.eye.skywalking.alarm.model.ApplicationInfo;
import com.a.eye.skywalking.alarm.model.UserInfo;
import com.a.eye.skywalking.alarm.util.DBConnectUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/SystemConfigDao.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/dao/SystemConfigDao.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.dao;
package com.a.eye.skywalking.alarm.dao;
import com.ai.cloud.skywalking.alarm.util.DBConnectUtil;
import com.a.eye.skywalking.alarm.util.DBConnectUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/AlarmRule.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/model/AlarmRule.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.model;
package com.a.eye.skywalking.alarm.model;
import com.ai.cloud.skywalking.alarm.util.RedisUtil;
import com.ai.cloud.skywalking.alarm.util.RedisUtil.Executable;
import com.a.eye.skywalking.alarm.util.RedisUtil;
import com.google.gson.Gson;
import redis.clients.jedis.Jedis;
......@@ -81,7 +80,7 @@ public class AlarmRule {
}
private static long getPreviousFireTime(final String userId, final String ruleId) {
return RedisUtil.execute(new Executable<Long>() {
return RedisUtil.execute(new RedisUtil.Executable<Long>() {
@Override
public Long exe(Jedis client) {
String previousTime = client.get(userId + "-" + ruleId);
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/ApplicationInfo.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/model/ApplicationInfo.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.model;
package com.a.eye.skywalking.alarm.model;
public class ApplicationInfo {
private String appId;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/ConfigArgsDescriber.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/model/ConfigArgsDescriber.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.model;
package com.a.eye.skywalking.alarm.model;
public class ConfigArgsDescriber {
private int period;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/MailInfo.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/model/MailInfo.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.model;
package com.a.eye.skywalking.alarm.model;
public class MailInfo {
private String[] mailTo;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/ProcessThreadStatus.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/model/ProcessThreadStatus.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.model;
package com.a.eye.skywalking.alarm.model;
public enum ProcessThreadStatus {
REDISTRIBUTING(1), REDISTRIBUTE_SUCCESS(2), FREE(0), BUSY(3);
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/procesor/AlarmMessageProcessor.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.procesor;
package com.a.eye.skywalking.alarm.procesor;
import java.io.IOException;
import java.io.StringWriter;
......@@ -14,22 +14,21 @@ import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import com.a.eye.skywalking.alarm.model.AlarmRule;
import com.a.eye.skywalking.alarm.model.AlarmType;
import com.a.eye.skywalking.alarm.model.ApplicationInfo;
import com.a.eye.skywalking.alarm.model.MailInfo;
import com.a.eye.skywalking.alarm.util.RedisUtil;
import com.a.eye.skywalking.alarm.util.TemplateConfigurationUtil;
import com.a.eye.skywalking.alarm.util.MailUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import redis.clients.jedis.Jedis;
import com.ai.cloud.skywalking.alarm.model.AlarmMessage;
import com.ai.cloud.skywalking.alarm.model.AlarmRule;
import com.ai.cloud.skywalking.alarm.model.AlarmType;
import com.ai.cloud.skywalking.alarm.model.ApplicationInfo;
import com.ai.cloud.skywalking.alarm.model.MailInfo;
import com.ai.cloud.skywalking.alarm.model.UserInfo;
import com.ai.cloud.skywalking.alarm.util.AlarmTypeUtil;
import com.ai.cloud.skywalking.alarm.util.MailUtil;
import com.ai.cloud.skywalking.alarm.util.RedisUtil;
import com.ai.cloud.skywalking.alarm.util.RedisUtil.Executable;
import com.ai.cloud.skywalking.alarm.util.TemplateConfigurationUtil;
import com.a.eye.skywalking.alarm.model.AlarmMessage;
import com.a.eye.skywalking.alarm.model.UserInfo;
import com.a.eye.skywalking.alarm.util.AlarmTypeUtil;
import freemarker.template.Template;
import freemarker.template.TemplateException;
......@@ -42,7 +41,7 @@ public class AlarmMessageProcessor {
private static final String TYPE_OF_EXCEPTION_WARNING = "default";
static List<AlarmType> alarmTypeList;
static Template t;
static Template t;
static {
alarmTypeList = AlarmTypeUtil.getAlarmTypeList();
......@@ -157,7 +156,7 @@ public class AlarmMessageProcessor {
}
private void expiredAlarmMessage(final String key) {
RedisUtil.execute(new Executable<Long>() {
RedisUtil.execute(new RedisUtil.Executable<Long>() {
@Override
public Long exe(Jedis client) {
return client.expire(key, 0);
......@@ -167,7 +166,7 @@ public class AlarmMessageProcessor {
private void savePreviousFireTime(final String userId, final String ruleId,
final long currentFireMinuteTime) {
RedisUtil.execute(new Executable<Long>() {
RedisUtil.execute(new RedisUtil.Executable<Long>() {
@Override
public Long exe(Jedis client) {
return client.hset(userId, ruleId,
......@@ -178,7 +177,7 @@ public class AlarmMessageProcessor {
private void setAlarmMessages(final String key,
final Collection<AlarmMessage> warningTracingIds) {
RedisUtil.execute(new Executable<Object>() {
RedisUtil.execute(new RedisUtil.Executable<Object>() {
@Override
public Collection<String> exe(Jedis client) {
Map<String, String> result = client.hgetAll(key);
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/AlarmTypeUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/AlarmTypeUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import java.util.ArrayList;
import java.util.List;
import com.a.eye.skywalking.alarm.dao.SystemConfigDao;
import com.a.eye.skywalking.alarm.model.AlarmType;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.SystemConfigDao;
import com.ai.cloud.skywalking.alarm.model.AlarmType;
import com.a.eye.skywalking.alarm.conf.Config;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/DBConnectUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/DBConnectUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.conf.Config;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import org.apache.logging.log4j.LogManager;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/MD5Encryption.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/MD5Encryption.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......@@ -32,4 +32,4 @@ public class MD5Encryption {
}
return result.toUpperCase();
}
}
\ No newline at end of file
}
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/MailUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/MailUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import java.util.Properties;
......@@ -11,11 +11,11 @@ import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.dao.SystemConfigDao;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.SystemConfigDao;
import com.google.gson.Gson;
public class MailUtil {
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/ProcessUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/ProcessUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadStatus;
import com.ai.cloud.skywalking.alarm.model.ProcessThreadValue;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.model.ProcessThreadStatus;
import com.a.eye.skywalking.alarm.model.ProcessThreadValue;
import com.google.gson.Gson;
public class ProcessUtil {
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/RedisUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/RedisUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.apache.logging.log4j.LogManager;
......@@ -7,7 +7,7 @@ import org.apache.logging.log4j.Logger;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.conf.Config;
public class RedisUtil {
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/TemplateConfigurationUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/TemplateConfigurationUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import java.io.File;
import java.io.IOException;
import java.sql.SQLException;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.ai.cloud.skywalking.alarm.dao.SystemConfigDao;
import com.a.eye.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.dao.SystemConfigDao;
import freemarker.template.Configuration;
import freemarker.template.TemplateModelException;
......
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/util/ZKUtil.java → skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/util/ZKUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.alarm.util;
package com.a.eye.skywalking.alarm.util;
import com.ai.cloud.skywalking.alarm.conf.Config;
import com.a.eye.skywalking.alarm.conf.Config;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
......
skywalking-analysis/pom.xml
浏览文件 @ 944160d2
......@@ -2,7 +2,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-analysis</artifactId>
<version>1.0-Final</version>
<packaging>jar</packaging>
......@@ -34,7 +34,7 @@
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.ai.cloud</groupId>
<groupId>com.a.eye</groupId>
<artifactId>skywalking-protocol</artifactId>
<version>1.0-Final</version>
</dependency>
......@@ -105,7 +105,7 @@
<transformers>
<transformer
implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<mainClass>com.ai.cloud.skywalking.analysis.AnalysisServerDriver</mainClass>
<mainClass>com.a.eye.skywalking.analysis.AnalysisServerDriver</mainClass>
</transformer>
</transformers>
</configuration>
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/AnalysisServerDriver.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis;
package com.a.eye.skywalking.analysis;
import com.ai.cloud.skywalking.analysis.chainbuild.ChainBuildMapper;
import com.ai.cloud.skywalking.analysis.chainbuild.ChainBuildReducer;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.ai.cloud.skywalking.analysis.config.ConfigInitializer;
import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.ChainBuildMapper;
import com.a.eye.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.ChainBuildReducer;
import com.a.eye.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.config.ConfigInitializer;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.hbase.client.Scan;
......@@ -56,7 +56,7 @@ public class AnalysisServerDriver extends Configured implements Tool {
conf.set("mapred.child.java.opts", Config.MapReduce.JAVA_OPTS);
String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
if (otherArgs.length != 2) {
System.err.println("Usage: com.ai.cloud.skywalking.analysis.AnalysisServerDriver yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss");
System.err.println("Usage: AnalysisServerDriver yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss");
System.exit(2);
}
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/ChainBuildMapper.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/ChainBuildMapper.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild;
import com.ai.cloud.skywalking.analysis.chainbuild.exception.Tid2CidECovertException;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessChain;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainInfo;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SummaryType;
import com.ai.cloud.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.ai.cloud.skywalking.analysis.chainbuild.util.TokenGenerator;
import com.ai.cloud.skywalking.analysis.chainbuild.util.VersionIdentifier;
import com.ai.cloud.skywalking.analysis.config.ConfigInitializer;
import com.ai.cloud.skywalking.protocol.AckSpan;
import com.ai.cloud.skywalking.protocol.FullSpan;
import com.ai.cloud.skywalking.protocol.RequestSpan;
import com.ai.cloud.skywalking.protocol.util.SpanLevelIdComparators;
package com.a.eye.skywalking.analysis.chainbuild;
import com.a.eye.skywalking.analysis.chainbuild.exception.Tid2CidECovertException;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.SummaryType;
import com.a.eye.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessChain;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainInfo;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.util.TokenGenerator;
import com.a.eye.skywalking.analysis.chainbuild.util.VersionIdentifier;
import com.a.eye.skywalking.analysis.config.ConfigInitializer;
import com.a.eye.skywalking.protocol.FullSpan;
import com.a.eye.skywalking.protocol.util.SpanLevelIdComparators;
import com.google.gson.Gson;
import com.google.protobuf.InvalidProtocolBufferException;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableMapper;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/ChainBuildReducer.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/ChainBuildReducer.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild;
package com.a.eye.skywalking.analysis.chainbuild;
import java.io.IOException;
import java.util.Iterator;
import com.a.eye.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.a.eye.skywalking.analysis.chainbuild.po.SummaryType;
import com.a.eye.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.config.ConfigInitializer;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SummaryType;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.ai.cloud.skywalking.analysis.config.ConfigInitializer;
public class ChainBuildReducer extends Reducer<Text, Text, Text, IntWritable> {
private Logger logger = LogManager.getLogger(ChainBuildReducer.class);
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/DBCallChainInfoDao.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild;
package com.a.eye.skywalking.analysis.chainbuild;
import java.sql.Connection;
import java.sql.DriverManager;
......@@ -9,9 +9,9 @@ import java.sql.Timestamp;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.CallChainDetailForMysql;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.chainbuild.entity.CallChainDetailForMysql;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.config.Config;
public class DBCallChainInfoDao {
private static Logger logger = LoggerFactory
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/SpanEntry.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/SpanEntry.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild;
package com.a.eye.skywalking.analysis.chainbuild;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.protocol.FullSpan;
import com.ai.cloud.skywalking.protocol.common.CallType;
import com.ai.cloud.skywalking.protocol.Span;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.protocol.FullSpan;
import com.a.eye.skywalking.protocol.common.CallType;
public class SpanEntry {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/action/impl/CallChainRelationshipAction.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/action/impl/CallChainRelationshipAction.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.action.impl;
package com.a.eye.skywalking.analysis.chainbuild.action.impl;
import java.io.IOException;
import java.sql.SQLException;
import com.ai.cloud.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.CallChainTree;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainInfo;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SpecificTimeCallChainTreeContainer;
import com.a.eye.skywalking.analysis.chainbuild.entity.CallChainTree;
import com.a.eye.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainInfo;
import com.a.eye.skywalking.analysis.chainbuild.po.SpecificTimeCallChainTreeContainer;
import com.google.gson.Gson;
public class CallChainRelationshipAction implements IStatisticsAction {
private CallChainTree chainTree;
private CallChainTree chainTree;
private SpecificTimeCallChainTreeContainer container;
public CallChainRelationshipAction(String entryKey) throws IOException {
chainTree = CallChainTree.create(entryKey);
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/action/impl/NumberOfCalledStatisticsAction.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/action/impl/NumberOfCalledStatisticsAction.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.action.impl;
package com.a.eye.skywalking.analysis.chainbuild.action.impl;
import java.io.IOException;
import java.sql.SQLException;
import com.ai.cloud.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.CallChainTree;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.CallChainTreeNode;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.ChainNodeSpecificTimeWindowSummaryValue;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SummaryType;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.a.eye.skywalking.analysis.chainbuild.entity.CallChainTree;
import com.a.eye.skywalking.analysis.chainbuild.entity.CallChainTreeNode;
import com.a.eye.skywalking.analysis.chainbuild.entity.ChainNodeSpecificTimeWindowSummaryValue;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.SummaryType;
import com.google.gson.Gson;
public class NumberOfCalledStatisticsAction implements IStatisticsAction {
private CallChainTree callChainTree;
private String summaryDate;
private SummaryType summaryType;
private String summaryDate;
private SummaryType summaryType;
/**
* 统计任务的主要存储值
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import java.sql.SQLException;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import com.ai.cloud.skywalking.analysis.chainbuild.DBCallChainInfoDao;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainInfo;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.DBCallChainInfoDao;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainInfo;
import com.google.gson.Gson;
public class CallChainDetailForMysql {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTree.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/CallChainTree.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import com.a.eye.skywalking.analysis.chainbuild.po.SummaryType;
import com.a.eye.skywalking.analysis.chainbuild.util.TokenGenerator;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SummaryType;
import com.ai.cloud.skywalking.analysis.chainbuild.util.TokenGenerator;
public class CallChainTree {
private Logger logger = LogManager.getLogger(CallChainTree.class);
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/CallChainTreeNode.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.po.SummaryType;
import com.ai.cloud.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.SummaryType;
import com.a.eye.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.a.eye.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.config.HBaseTableMetaData;
import com.google.gson.GsonBuilder;
import com.google.gson.annotations.Expose;
import org.apache.hadoop.hbase.client.Put;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/ChainNodeSpecificDaySummary.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/ChainNodeSpecificDaySummary.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/ChainNodeSpecificHourSummary.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/ChainNodeSpecificHourSummary.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/ChainNodeSpecificMinSummary.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/ChainNodeSpecificMinSummary.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import java.util.HashMap;
import java.util.Map;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/ChainNodeSpecificMonthSummary.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/ChainNodeSpecificMonthSummary.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/ChainNodeSpecificTimeWindowSummaryValue.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/entity/ChainNodeSpecificTimeWindowSummaryValue.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.entity;
package com.a.eye.skywalking.analysis.chainbuild.entity;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
public class ChainNodeSpecificTimeWindowSummaryValue {
private long totalCall;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/exception/Tid2CidECovertException.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/exception/Tid2CidECovertException.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.exception;
package com.a.eye.skywalking.analysis.chainbuild.exception;
public class Tid2CidECovertException extends Exception{
private static final long serialVersionUID = -4679233837335940374L;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/SpanNodeProcessChain.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/SpanNodeProcessChain.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter;
package com.a.eye.skywalking.analysis.chainbuild.filter;
import java.io.IOException;
import java.util.HashMap;
......@@ -8,7 +8,7 @@ import java.util.Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.a.eye.skywalking.analysis.config.Config;
public class SpanNodeProcessChain {
private static Logger logger = LoggerFactory.getLogger(SpanNodeProcessChain.class.getName());
......@@ -51,7 +51,7 @@ public class SpanNodeProcessChain {
System.exit(-1);
} catch (ClassCastException e) {
logger.error("Class [" + Config.Filter.FILTER_PACKAGE_NAME + "." + filters[i] + "] is not subclass of " +
"com.ai.cloud.skywalking.analysis.filter.SpanNodeProcessFilter", e);
"com.a.eye.skywalking.analysis.filter.SpanNodeProcessFilter", e);
System.exit(-1);
}
}
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/SpanNodeProcessFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/SpanNodeProcessFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter;
package com.a.eye.skywalking.analysis.chainbuild.filter;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
public abstract class SpanNodeProcessFilter {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/AppendBusinessKeyFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/AppendBusinessKeyFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
public class AppendBusinessKeyFilter extends SpanNodeProcessFilter {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/CopyAttrFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/CopyAttrFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
public class CopyAttrFilter extends SpanNodeProcessFilter {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/JDBCBusinessKeyHandleFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/JDBCBusinessKeyHandleFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
public class JDBCBusinessKeyHandleFilter extends SpanNodeProcessFilter {
private Logger logger = LogManager.getLogger(JDBCBusinessKeyHandleFilter.class);
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/ProcessCostTimeFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/ProcessCostTimeFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
public class ProcessCostTimeFilter extends SpanNodeProcessFilter {
@Override
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/ReplaceAddressFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/ReplaceAddressFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
public class ReplaceAddressFilter extends SpanNodeProcessFilter {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/filter/impl/TokenGenerateFilter.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/filter/impl/TokenGenerateFilter.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.filter.impl;
package com.a.eye.skywalking.analysis.chainbuild.filter.impl;
import com.ai.cloud.skywalking.analysis.chainbuild.SpanEntry;
import com.ai.cloud.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
import com.ai.cloud.skywalking.analysis.chainbuild.po.ChainNode;
import com.ai.cloud.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.ai.cloud.skywalking.analysis.chainbuild.util.TokenGenerator;
import com.a.eye.skywalking.analysis.chainbuild.SpanEntry;
import com.a.eye.skywalking.analysis.chainbuild.po.ChainNode;
import com.a.eye.skywalking.analysis.chainbuild.util.SubLevelSpanCostCounter;
import com.a.eye.skywalking.analysis.chainbuild.util.TokenGenerator;
import com.a.eye.skywalking.analysis.chainbuild.filter.SpanNodeProcessFilter;
public class TokenGenerateFilter extends SpanNodeProcessFilter {
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/ChainInfo.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/po/ChainInfo.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.po;
package com.a.eye.skywalking.analysis.chainbuild.po;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.exception.Tid2CidECovertException;
import com.a.eye.skywalking.analysis.chainbuild.util.TokenGenerator;
import com.a.eye.skywalking.analysis.config.HBaseTableMetaData;
import org.apache.hadoop.hbase.client.Put;
import com.ai.cloud.skywalking.analysis.chainbuild.exception.Tid2CidECovertException;
import com.ai.cloud.skywalking.analysis.chainbuild.util.TokenGenerator;
public class ChainInfo implements Serializable {
private static final long serialVersionUID = -7194044877533469817L;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/ChainNode.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/po/ChainNode.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.po;
package com.a.eye.skywalking.analysis.chainbuild.po;
import com.google.gson.GsonBuilder;
import com.google.gson.annotations.Expose;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallChainTreeContainer.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/po/SpecificTimeCallChainTreeContainer.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.po;
package com.a.eye.skywalking.analysis.chainbuild.po;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.CallChainDetailForMysql;
import com.ai.cloud.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.util.HBaseUtil;
import com.a.eye.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.entity.CallChainDetailForMysql;
import com.google.gson.Gson;
import org.apache.hadoop.hbase.client.Put;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SummaryType.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/po/SummaryType.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.po;
package com.a.eye.skywalking.analysis.chainbuild.po;
import com.ai.cloud.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.ai.cloud.skywalking.analysis.chainbuild.action.impl.NumberOfCalledStatisticsAction;
import com.ai.cloud.skywalking.analysis.chainbuild.action.impl.CallChainRelationshipAction;
import com.a.eye.skywalking.analysis.chainbuild.action.IStatisticsAction;
import com.a.eye.skywalking.analysis.chainbuild.action.impl.CallChainRelationshipAction;
import com.a.eye.skywalking.analysis.chainbuild.action.impl.NumberOfCalledStatisticsAction;
import java.io.IOException;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/util/CellToSpanHandler.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/util/CellToSpanHandler.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.util;
package com.a.eye.skywalking.analysis.chainbuild.util;
import com.ai.cloud.skywalking.protocol.AckSpan;
import com.ai.cloud.skywalking.protocol.FullSpan;
import com.ai.cloud.skywalking.protocol.RequestSpan;
import com.ai.cloud.skywalking.protocol.exception.ConvertFailedException;
import com.a.eye.skywalking.protocol.AckSpan;
import com.a.eye.skywalking.protocol.FullSpan;
import com.a.eye.skywalking.protocol.RequestSpan;
import com.a.eye.skywalking.protocol.exception.ConvertFailedException;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.util.Bytes;
......
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/util/HBaseUtil.java → skywalking-analysis/src/main/java/com/a/eye/skywalking/analysis/chainbuild/util/HBaseUtil.java
浏览文件 @ 944160d2
package com.ai.cloud.skywalking.analysis.chainbuild.util;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.ChainNodeSpecificDaySummary;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.ChainNodeSpecificHourSummary;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.ChainNodeSpecificMinSummary;
import com.ai.cloud.skywalking.analysis.chainbuild.entity.ChainNodeSpecificMonthSummary;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.ai.cloud.skywalking.analysis.config.HBaseTableMetaData;
import com.ai.cloud.skywalking.protocol.FullSpan;
import com.ai.cloud.skywalking.protocol.exception.ConvertFailedException;
package com.a.eye.skywalking.analysis.chainbuild.util;
import com.a.eye.skywalking.analysis.chainbuild.entity.ChainNodeSpecificMinSummary;
import com.a.eye.skywalking.analysis.config.HBaseTableMetaData;
import com.a.eye.skywalking.analysis.chainbuild.entity.ChainNodeSpecificDaySummary;
import com.a.eye.skywalking.analysis.chainbuild.entity.ChainNodeSpecificHourSummary;
import com.a.eye.skywalking.analysis.chainbuild.entity.ChainNodeSpecificMonthSummary;
import com.a.eye.skywalking.analysis.config.Config;
import com.a.eye.skywalking.protocol.FullSpan;
import com.a.eye.skywalking.protocol.exception.ConvertFailedException;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import org.apache.hadoop.conf.Configuration;
......
skywalking-collector/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
skywalking-collector/skywalking-log/pom.xml 已删除 100644 → 0
浏览文件 @ c9b6eade
此差异已折叠。
skywalking-protocol/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
skywalking-server/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
skywalking-webui/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
test/skywalking-agent-test/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
test/skywalking-test-api/pom.xml
浏览文件 @ 944160d2
此差异已折叠。
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或