Merge branch 'master' into enhancement/rollover_api
Original commit: elastic/x-pack-elasticsearch@0217fa2a12
This commit is contained in:
commit
384861ef75
|
@ -34,16 +34,6 @@ public class Graph extends Plugin {
|
||||||
enabled = enabled(settings);
|
enabled = enabled(settings);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "Elasticsearch Graph Plugin";
|
|
||||||
}
|
|
||||||
|
|
||||||
public static boolean enabled(Settings settings) {
|
public static boolean enabled(Settings settings) {
|
||||||
return XPackPlugin.featureEnabled(settings, NAME, true);
|
return XPackPlugin.featureEnabled(settings, NAME, true);
|
||||||
}
|
}
|
||||||
|
|
|
@ -350,16 +350,6 @@ public class GraphTests extends ESSingleNodeTestCase {
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class ScriptedTimeoutPlugin extends Plugin implements ScriptPlugin {
|
public static class ScriptedTimeoutPlugin extends Plugin implements ScriptPlugin {
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return "test-scripted-graph-timeout";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "Test for scripted timeouts on graph searches";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<NativeScriptFactory> getNativeScripts() {
|
public List<NativeScriptFactory> getNativeScripts() {
|
||||||
return Collections.singletonList(new NativeTestScriptedTimeout.Factory());
|
return Collections.singletonList(new NativeTestScriptedTimeout.Factory());
|
||||||
|
|
|
@ -28,11 +28,6 @@ public class EagerLicenseRegistrationConsumerPlugin extends TestConsumerPluginBa
|
||||||
return EagerLicenseRegistrationPluginService.class;
|
return EagerLicenseRegistrationPluginService.class;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected String pluginName() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String id() {
|
public String id() {
|
||||||
return EagerLicenseRegistrationPluginService.ID;
|
return EagerLicenseRegistrationPluginService.ID;
|
||||||
|
|
|
@ -16,8 +16,6 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
*/
|
*/
|
||||||
public class LazyLicenseRegistrationConsumerPlugin extends TestConsumerPluginBase {
|
public class LazyLicenseRegistrationConsumerPlugin extends TestConsumerPluginBase {
|
||||||
|
|
||||||
public static String NAME = "test_consumer_plugin_2";
|
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public LazyLicenseRegistrationConsumerPlugin(Settings settings) {
|
public LazyLicenseRegistrationConsumerPlugin(Settings settings) {
|
||||||
super(settings);
|
super(settings);
|
||||||
|
@ -28,11 +26,6 @@ public class LazyLicenseRegistrationConsumerPlugin extends TestConsumerPluginBas
|
||||||
return LazyLicenseRegistrationPluginService.class;
|
return LazyLicenseRegistrationPluginService.class;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected String pluginName() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String id() {
|
public String id() {
|
||||||
return LazyLicenseRegistrationPluginService.ID;
|
return LazyLicenseRegistrationPluginService.ID;
|
||||||
|
|
|
@ -26,17 +26,6 @@ public abstract class TestConsumerPluginBase extends Plugin {
|
||||||
this.isEnabled = TransportClient.CLIENT_TYPE.equals(settings.get(Client.CLIENT_TYPE_SETTING_S.getKey())) == false;
|
this.isEnabled = TransportClient.CLIENT_TYPE.equals(settings.get(Client.CLIENT_TYPE_SETTING_S.getKey())) == false;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return pluginName();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "test licensing consumer plugin";
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Collection<Class<? extends LifecycleComponent>> nodeServices() {
|
public Collection<Class<? extends LifecycleComponent>> nodeServices() {
|
||||||
Collection<Class<? extends LifecycleComponent>> services = new ArrayList<>();
|
Collection<Class<? extends LifecycleComponent>> services = new ArrayList<>();
|
||||||
|
@ -55,7 +44,5 @@ public abstract class TestConsumerPluginBase extends Plugin {
|
||||||
|
|
||||||
public abstract Class<? extends TestPluginServiceBase> service();
|
public abstract Class<? extends TestPluginServiceBase> service();
|
||||||
|
|
||||||
protected abstract String pluginName();
|
|
||||||
|
|
||||||
public abstract String id();
|
public abstract String id();
|
||||||
}
|
}
|
||||||
|
|
|
@ -79,7 +79,7 @@ public class MarvelPluginTests extends MarvelIntegTestCase {
|
||||||
for (PluginInfo plugin : nodeInfo.getPlugins().getPluginInfos()) {
|
for (PluginInfo plugin : nodeInfo.getPlugins().getPluginInfos()) {
|
||||||
assertNotNull(plugin);
|
assertNotNull(plugin);
|
||||||
|
|
||||||
if (XPackPlugin.NAME.equals(plugin.getName())) {
|
if (XPackPlugin.class.getName().equals(plugin.getName())) {
|
||||||
found = true;
|
found = true;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,13 +19,13 @@ public class Exceptions {
|
||||||
|
|
||||||
public static ElasticsearchSecurityException authenticationError(String msg, Throwable cause, Object... args) {
|
public static ElasticsearchSecurityException authenticationError(String msg, Throwable cause, Object... args) {
|
||||||
ElasticsearchSecurityException e = new ElasticsearchSecurityException(msg, RestStatus.UNAUTHORIZED, cause, args);
|
ElasticsearchSecurityException e = new ElasticsearchSecurityException(msg, RestStatus.UNAUTHORIZED, cause, args);
|
||||||
e.addHeader("WWW-Authenticate", "Basic realm=\"" + Security.NAME + "\"");
|
e.addHeader("WWW-Authenticate", "Basic realm=\"" + Security.NAME + "\" charset=\"UTF-8\"");
|
||||||
return e;
|
return e;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static ElasticsearchSecurityException authenticationError(String msg, Object... args) {
|
public static ElasticsearchSecurityException authenticationError(String msg, Object... args) {
|
||||||
ElasticsearchSecurityException e = new ElasticsearchSecurityException(msg, RestStatus.UNAUTHORIZED, args);
|
ElasticsearchSecurityException e = new ElasticsearchSecurityException(msg, RestStatus.UNAUTHORIZED, args);
|
||||||
e.addHeader("WWW-Authenticate", "Basic realm=\"" + Security.NAME + "\"");
|
e.addHeader("WWW-Authenticate", "Basic realm=\"" + Security.NAME + "\" charset=\"UTF-8\"");
|
||||||
return e;
|
return e;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -21,6 +21,6 @@ public class ShieldAssertions {
|
||||||
assertThat(e.status(), is(RestStatus.UNAUTHORIZED));
|
assertThat(e.status(), is(RestStatus.UNAUTHORIZED));
|
||||||
assertThat(e.getHeaderKeys(), hasSize(1));
|
assertThat(e.getHeaderKeys(), hasSize(1));
|
||||||
assertThat(e.getHeader("WWW-Authenticate"), notNullValue());
|
assertThat(e.getHeader("WWW-Authenticate"), notNullValue());
|
||||||
assertThat(e.getHeader("WWW-Authenticate"), contains("Basic realm=\"" + Security.NAME + "\""));
|
assertThat(e.getHeader("WWW-Authenticate"), contains("Basic realm=\"" + Security.NAME + "\" charset=\"UTF-8\""));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -116,16 +116,6 @@ public class TransportFilterTests extends ESIntegTestCase {
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class InternalPlugin extends Plugin {
|
public static class InternalPlugin extends Plugin {
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return "test-transport-filter";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Collection<Module> nodeModules() {
|
public Collection<Module> nodeModules() {
|
||||||
return Collections.<Module>singletonList(new TestTransportFilterModule());
|
return Collections.<Module>singletonList(new TestTransportFilterModule());
|
||||||
|
@ -289,14 +279,6 @@ public class TransportFilterTests extends ESIntegTestCase {
|
||||||
// Sub class the Shield transport to always inject a mock for testing
|
// Sub class the Shield transport to always inject a mock for testing
|
||||||
public static class InternalPluginServerTransportService extends ShieldServerTransportService {
|
public static class InternalPluginServerTransportService extends ShieldServerTransportService {
|
||||||
public static class TestPlugin extends Plugin {
|
public static class TestPlugin extends Plugin {
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return "mock-transport-service";
|
|
||||||
}
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "a mock transport service for testing";
|
|
||||||
}
|
|
||||||
public void onModule(NetworkModule module) {
|
public void onModule(NetworkModule module) {
|
||||||
module.registerTransportService("filter-mock", InternalPluginServerTransportService.class);
|
module.registerTransportService("filter-mock", InternalPluginServerTransportService.class);
|
||||||
}
|
}
|
||||||
|
|
|
@ -151,7 +151,8 @@ public abstract class ShieldIntegTestCase extends ESIntegTestCase {
|
||||||
// assertThat(nodeInfo.getPlugins().getInfos(), hasSize(2));
|
// assertThat(nodeInfo.getPlugins().getInfos(), hasSize(2));
|
||||||
Collection<String> pluginNames =
|
Collection<String> pluginNames =
|
||||||
nodeInfo.getPlugins().getPluginInfos().stream().map(p -> p.getName()).collect(Collectors.toList());
|
nodeInfo.getPlugins().getPluginInfos().stream().map(p -> p.getName()).collect(Collectors.toList());
|
||||||
assertThat("plugin [" + XPackPlugin.NAME + "] not found in [" + pluginNames + "]", pluginNames, hasItem(XPackPlugin.NAME));
|
assertThat("plugin [" + xpackPluginClass().getName() + "] not found in [" + pluginNames + "]", pluginNames,
|
||||||
|
hasItem(xpackPluginClass().getName()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -127,14 +127,6 @@ public class XPackPlugin extends Plugin implements ScriptPlugin {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override public String name() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override public String description() {
|
|
||||||
return "Elastic X-Pack";
|
|
||||||
}
|
|
||||||
|
|
||||||
// For tests only
|
// For tests only
|
||||||
public Collection<Class<? extends XPackExtension>> getExtensions() {
|
public Collection<Class<? extends XPackExtension>> getExtensions() {
|
||||||
return Collections.emptyList();
|
return Collections.emptyList();
|
||||||
|
|
|
@ -20,12 +20,6 @@ public class MockMustacheScriptEngine extends MockScriptEngine {
|
||||||
public static final String NAME = "mustache";
|
public static final String NAME = "mustache";
|
||||||
|
|
||||||
public static class TestPlugin extends MockScriptEngine.TestPlugin {
|
public static class TestPlugin extends MockScriptEngine.TestPlugin {
|
||||||
|
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ScriptEngineService getScriptEngineService(Settings settings) {
|
public ScriptEngineService getScriptEngineService(Settings settings) {
|
||||||
return new MockMustacheScriptEngine();
|
return new MockMustacheScriptEngine();
|
||||||
|
|
|
@ -23,20 +23,6 @@ public class SleepScriptEngine implements ScriptEngineService {
|
||||||
public static final String NAME = "sleep";
|
public static final String NAME = "sleep";
|
||||||
|
|
||||||
public static class TestPlugin extends Plugin implements ScriptPlugin {
|
public static class TestPlugin extends Plugin implements ScriptPlugin {
|
||||||
|
|
||||||
public TestPlugin() {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return NAME;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "Mock script engine for integration tests";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ScriptEngineService getScriptEngineService(Settings settings) {
|
public ScriptEngineService getScriptEngineService(Settings settings) {
|
||||||
return new SleepScriptEngine();
|
return new SleepScriptEngine();
|
||||||
|
|
|
@ -112,19 +112,6 @@ public class ActionErrorIntegrationTests extends AbstractWatcherIntegrationTestC
|
||||||
|
|
||||||
public static class ErrorActionPlugin extends Plugin {
|
public static class ErrorActionPlugin extends Plugin {
|
||||||
|
|
||||||
public ErrorActionPlugin() {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String name() {
|
|
||||||
return "error-action";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return name();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void onModule(WatcherActionModule module) {
|
public void onModule(WatcherActionModule module) {
|
||||||
module.registerAction(ErrorAction.TYPE, ErrorAction.Factory.class);
|
module.registerAction(ErrorAction.TYPE, ErrorAction.Factory.class);
|
||||||
}
|
}
|
||||||
|
|
|
@ -76,14 +76,6 @@ public class WatcherIndexTemplateRegistryTests extends AbstractWatcherIntegratio
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class SettingTestPlugin extends Plugin {
|
public static class SettingTestPlugin extends Plugin {
|
||||||
public String name() {
|
|
||||||
return "watcher-index-template-registry-settings-plugin";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String description() {
|
|
||||||
return "installs a setting this test needs";
|
|
||||||
}
|
|
||||||
|
|
||||||
public static final Setting<String> KEY_1 = new Setting<>("index.key1", "", Function.identity(), Setting.Property.IndexScope);
|
public static final Setting<String> KEY_1 = new Setting<>("index.key1", "", Function.identity(), Setting.Property.IndexScope);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue