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

Add mechanism to set default status(on/off) of plugin

This commit is contained in:
ascrutae 2017-06-26 11:23:19 +08:00
parent 0b4b4b1759
commit ace2e63887
2 changed files with 30 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/conf/Config.java
View File

@ -101,6 +101,12 @@ public class Config {
*/ */
public static List DISABLED_PLUGINS = new LinkedList(); public static List DISABLED_PLUGINS = new LinkedList();
/**
* Name of force enable plugin, The value spilt by <code>,</code>
* if you have multiple plugins need to enable.
*/
public static List FORCE_ENABLE_PLUGINS = new LinkedList();
public static class MongoDB { public static class MongoDB {
/** /**
* If true, trace all the parameters, default is false. * If true, trace all the parameters, default is false.

27
apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/plugin/PluginDefine.java
View File

@ -15,9 +15,15 @@ public class PluginDefine {
*/ */
private String defineClass; private String defineClass;
private PluginDefine(String name, String defineClass) { /**
* The sate of plugin.
*/
private State state;
private PluginDefine(String name, String defineClass, State state) {
this.name = name; this.name = name;
this.defineClass = defineClass; this.defineClass = defineClass;
this.state = state;
} }
public static PluginDefine build(String define) throws IllegalPluginDefineException { public static PluginDefine build(String define) throws IllegalPluginDefineException {
@ -30,16 +36,31 @@ public class PluginDefine {
throw new IllegalPluginDefineException(define); throw new IllegalPluginDefineException(define);
} }
return new PluginDefine(pluginDefine[0], pluginDefine[1]); String pluginName = pluginDefine[0];
String defineClass = pluginDefine[1];
if (pluginName.toUpperCase().startsWith("[OFF]")) {
return new PluginDefine(pluginName.substring(5), defineClass, State.OFF);
} else {
return new PluginDefine(pluginName, defineClass, State.ON);
}
} }
public boolean enable() { public boolean enable() {
return !Config.Plugin.DISABLED_PLUGINS.contains(name); return !Config.Plugin.DISABLED_PLUGINS.contains(name) || forceEnable();
}
private boolean forceEnable() {
return state == State.OFF && Config.Plugin.FORCE_ENABLE_PLUGINS.contains(name);
} }
public String getDefineClass() { public String getDefineClass() {
return defineClass; return defineClass;
} }
private enum State {
OFF, ON;
}
} }