kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1.增加MySQL存储的调用入口

This commit is contained in:
wusheng 2015-11-19 20:41:32 +08:00
parent a9bad1cd8f
commit 73f12a6f14
3 changed files with 35 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java
View File

@ -82,5 +82,7 @@ public class Config {
public static class StorageChain {
public static long RETRY_STORAGE_WAIT_TIME = 50L;
public static String STORAGE_TYPE = "hbase";
}
}

22
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java
View File

@ -1,13 +1,17 @@
package com.ai.cloud.skywalking.reciever.storage;
import static com.ai.cloud.skywalking.reciever.conf.Config.StorageChain.STORAGE_TYPE;
import java.util.ArrayList;
import java.util.List;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.reciever.conf.Config;
import com.ai.cloud.skywalking.reciever.model.BuriedPointEntry;
import com.ai.cloud.skywalking.reciever.storage.chain.SaveToHBaseChain;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.ArrayList;
import java.util.List;
import com.ai.cloud.skywalking.reciever.storage.chain.SaveToMySQLChain;
public class StorageChainController {
private static Logger logger = LogManager
@ -16,7 +20,13 @@ public class StorageChainController {
private static List<IStorageChain> chainArray = new ArrayList<IStorageChain>();
static {
chainArray.add(new SaveToHBaseChain());
if(STORAGE_TYPE.equalsIgnoreCase("hbase")){
chainArray.add(new SaveToHBaseChain());
}else if(STORAGE_TYPE.equalsIgnoreCase("mysql")){
chainArray.add(new SaveToMySQLChain());
}else{
throw new RuntimeException("illegal storage type.");
}
}
public static void doStorage(String buriedPointDatas) {

17
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java Normal file
View File

@ -0,0 +1,17 @@
package com.ai.cloud.skywalking.reciever.storage.chain;
import java.util.List;
import com.ai.cloud.skywalking.reciever.model.BuriedPointEntry;
import com.ai.cloud.skywalking.reciever.storage.Chain;
import com.ai.cloud.skywalking.reciever.storage.IStorageChain;
public class SaveToMySQLChain implements IStorageChain {
@Override
public void doChain(List<BuriedPointEntry> entry, Chain chain) {
// TODO Auto-generated method stub
}
}