diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java index 2c9ea9ab1..f3d3e0e06 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java @@ -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"; } } \ No newline at end of file diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java index d67c051e0..f5953513a 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java @@ -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 chainArray = new ArrayList(); 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) { diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java new file mode 100644 index 000000000..b79877ac2 --- /dev/null +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java @@ -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 entry, Chain chain) { + // TODO Auto-generated method stub + + } + +}