Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
34f6bb9d
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 搜索 >>
提交
34f6bb9d
编写于
11月 23, 2016
作者:
A
ascrutae
浏览文件
操作
浏览文件
下载
差异文件
Merge remote-tracking branch 'origin/master'
上级
6f85ca93
ba72fcc4
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
11 addition
and
11 deletion
+11
-11
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/Main.java
...rage/src/main/java/com/a/eye/skywalking/storage/Main.java
+2
-2
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/boot/ElasticBootstrap.java
...a/com/a/eye/skywalking/storage/boot/ElasticBootstrap.java
+4
-4
skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/boot/ElasticBootstrapTest.java
...m/a/eye/skywalking/storage/boot/ElasticBootstrapTest.java
+5
-5
未找到文件。
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/Main.java
浏览文件 @
34f6bb9d
...
...
@@ -9,7 +9,7 @@ import com.a.eye.skywalking.registry.RegistryCenterFactory;
import
com.a.eye.skywalking.registry.api.CenterType
;
import
com.a.eye.skywalking.registry.api.RegistryCenter
;
import
com.a.eye.skywalking.registry.impl.zookeeper.ZookeeperConfig
;
import
com.a.eye.skywalking.storage.boot.ElasticBoot
er
;
import
com.a.eye.skywalking.storage.boot.ElasticBoot
strap
;
import
com.a.eye.skywalking.storage.config.Config
;
import
com.a.eye.skywalking.storage.config.ConfigInitializer
;
import
com.a.eye.skywalking.storage.data.file.DataFilesManager
;
...
...
@@ -43,7 +43,7 @@ public class Main {
initializeParam
();
HealthCollector
.
init
(
SERVER_REPORTER_NAME
);
new
ElasticBoot
er
().
boot
(
NetUtils
.
getIndexServerPort
());
new
ElasticBoot
strap
().
boot
(
NetUtils
.
getIndexServerPort
());
IndexOperatorFactory
.
initOperatorPool
();
DataFilesManager
.
init
();
...
...
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/boot/ElasticBoot
er
.java
→
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/boot/ElasticBoot
strap
.java
浏览文件 @
34f6bb9d
...
...
@@ -9,16 +9,16 @@ import java.io.IOException;
/**
* Created by xin on 2016/11/20.
*/
public
class
ElasticBoot
er
{
public
class
ElasticBoot
strap
{
private
static
ILog
logger
=
LogManager
.
getLogger
(
ElasticBoot
er
.
class
);
private
static
ILog
logger
=
LogManager
.
getLogger
(
ElasticBoot
strap
.
class
);
public
static
final
String
DATA_INDEX_HOME
=
"DATA_INDEX_HOME"
;
private
static
final
String
DEVELOP_RUNTIME_ELASTIC_HOME
=
ElasticBoot
er
.
class
.
getResource
(
"/"
).
getPath
()
+
".."
+
File
.
separator
+
"install"
+
File
.
separator
+
"data"
ElasticBoot
strap
.
class
.
getResource
(
"/"
).
getPath
()
+
".."
+
File
.
separator
+
"install"
+
File
.
separator
+
"data"
+
File
.
separator
+
"index"
;
private
String
elasticHome
;
public
ElasticBoot
er
()
{
public
ElasticBoot
strap
()
{
this
.
elasticHome
=
fetchElasticHome
();
}
...
...
skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/boot/ElasticBoot
er
Test.java
→
skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/boot/ElasticBoot
strap
Test.java
浏览文件 @
34f6bb9d
...
...
@@ -5,23 +5,23 @@ import org.junit.Test;
import
java.io.File
;
import
static
com
.
a
.
eye
.
skywalking
.
storage
.
boot
.
ElasticBoot
er
.
DATA_INDEX_HOME
;
import
static
com
.
a
.
eye
.
skywalking
.
storage
.
boot
.
ElasticBoot
strap
.
DATA_INDEX_HOME
;
import
static
org
.
junit
.
Assert
.
assertEquals
;
public
class
ElasticBoot
er
Test
{
private
String
bastPath
=
ElasticBoot
er
Test
.
class
.
getResource
(
"/"
).
getPath
()
+
".."
+
File
.
separator
;
public
class
ElasticBoot
strap
Test
{
private
String
bastPath
=
ElasticBoot
strap
Test
.
class
.
getResource
(
"/"
).
getPath
()
+
".."
+
File
.
separator
;
@Test
public
void
fetchElasticHomeWithoutProperty
()
{
ElasticBoot
er
booter
=
new
ElasticBooter
();
ElasticBoot
strap
booter
=
new
ElasticBootstrap
();
assertEquals
(
"Elastic Home :"
,
booter
.
fetchElasticHome
(),
bastPath
+
"install/data/index"
);
}
@Test
public
void
fetchElasticHomeWithProperty
()
{
System
.
setProperty
(
DATA_INDEX_HOME
,
"/test/test"
);
ElasticBoot
er
fetcher
=
new
ElasticBooter
();
ElasticBoot
strap
fetcher
=
new
ElasticBootstrap
();
assertEquals
(
"Elastic Home :"
,
fetcher
.
fetchElasticHome
(),
"/test/test"
);
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录