提交 02118b4c 编写于 作者: A ascrutae

Merge remote-tracking branch 'origin/master'

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.protocol.Span;
import com.ai.cloud.skywalking.reciever.conf.Constants;
import com.ai.cloud.skywalking.reciever.selfexamination.ServerHealthCollector;
import com.ai.cloud.skywalking.reciever.selfexamination.ServerHeathReading;
import com.ai.cloud.skywalking.reciever.storage.chain.AlarmChain;
import com.ai.cloud.skywalking.reciever.storage.chain.SaveToHBaseChain;
import com.ai.cloud.skywalking.reciever.storage.chain.SaveToMySQLChain;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.ArrayList;
import java.util.List;
import static com.ai.cloud.skywalking.reciever.conf.Config.StorageChain.STORAGE_TYPE;
public class StorageChainController {
private static Logger logger = LogManager
......@@ -25,8 +25,6 @@ public class StorageChainController {
if (STORAGE_TYPE.equalsIgnoreCase("hbase")) {
chainArray.add(new AlarmChain());
chainArray.add(new SaveToHBaseChain());
} else if (STORAGE_TYPE.equalsIgnoreCase("mysql")) {
chainArray.add(new SaveToMySQLChain());
} else {
throw new RuntimeException("illegal storage type.");
}
......
package com.ai.cloud.skywalking.reciever.storage.chain;
import com.ai.cloud.skywalking.protocol.Span;
import com.ai.cloud.skywalking.reciever.storage.Chain;
import com.ai.cloud.skywalking.reciever.storage.IStorageChain;
import java.util.List;
public class SaveToMySQLChain implements IStorageChain {
@Override
public void doChain(List<Span> entry, Chain chain) {
// TODO Auto-generated method stub
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册