github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-23 17:28:26 -04:00
Code Issues Projects Releases Packages Wiki Activity

Added a version check for host Elasticsearch

Browse source
This commit is contained in:
Boaz Leskes 2013-12-23 12:18:18 +01:00
parent 4c4ea87b7f
commit c155484c2a
1 changed files with 22 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

23
exporter/src/main/java/org/elasticsearch/marvel/monitor/Plugin.java
View file

@ -19,10 +19,13 @@
package org.elasticsearch.marvel.monitor;
import org.elasticsearch.Version;
import org.elasticsearch.common.collect.ImmutableList;
import org.elasticsearch.common.component.LifecycleComponent;
import org.elasticsearch.common.inject.AbstractModule;
import org.elasticsearch.common.inject.Module;
import org.elasticsearch.common.logging.ESLogger;
import org.elasticsearch.common.logging.Loggers;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.plugins.AbstractPlugin;
@ -31,7 +34,20 @@ import java.util.Collection;
public class Plugin extends AbstractPlugin {
final ESLogger logger = Loggers.getLogger(getClass());
// copied here because we can't depend on it available
public static final int V_0_90_8_ID = /*00*/900899;
public final boolean enabled;
public Plugin() {
if (Version.CURRENT.id < V_0_90_8_ID) {
logger.warn("Elasticsearch version [{}] is too old. Marvel is disabled (requires version 0.90.8 or higher)", Version.CURRENT);
enabled = false;
} else {
enabled = true;
}
}
@Override
@ -46,6 +62,9 @@ public class Plugin extends AbstractPlugin {
@Override
public Collection<Module> modules(Settings settings) {
if (!enabled) {
return ImmutableList.of();
}
Module m = new AbstractModule() {
@Override
@ -59,7 +78,9 @@ public class Plugin extends AbstractPlugin {
@Override
public Collection<Class<? extends LifecycleComponent>> services() {
Collection<Class<? extends LifecycleComponent>> l = new ArrayList<Class<? extends LifecycleComponent>>();
l.add(ExportersService.class);
if (enabled) {
l.add(ExportersService.class);
}
return l;
}
}