honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactored to use Settings object

This commit is contained in:
Sarwar Bhuiyan 2016-08-25 17:27:22 -04:00
parent 1cf694b63e
commit b0ceecc3eb
1 changed files with 15 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
plugins/jvm-example/src/main/java/org/elasticsearch/plugin/example/ExamplePluginConfiguration.java
View File

@ -19,51 +19,38 @@
package org.elasticsearch.plugin.example;
import org.elasticsearch.ElasticsearchParseException;
import org.elasticsearch.common.inject.Inject;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.common.xcontent.yaml.YamlXContent;
import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import java.io.IOException;
import java.nio.file.Path;
import static java.nio.charset.StandardCharsets.UTF_8;
import static java.nio.file.Files.newBufferedReader;
import static org.elasticsearch.common.io.Streams.copyToString;
import java.util.Locale;
/**
* Example configuration.
*/
public class ExamplePluginConfiguration {
private String test = "not set in config";
private final Settings customSettings;
public static final Setting<String> TEST_SETTING =
new Setting<String>("test", "default_value",
(value) -> value, Setting.Property.Dynamic);
@Inject
public ExamplePluginConfiguration(Environment env) throws IOException {
// The directory part of the location matches the artifactId of this plugin
Path configFile = env.configFile().resolve("jvm-example/example.yaml");
String contents = copyToString(newBufferedReader(configFile, UTF_8));
XContentParser parser = YamlXContent.yamlXContent.createParser(contents);
Path path = env.configFile().resolve("jvm-example/example.yaml");
customSettings = Settings.builder().loadFromPath(path).build();
String currentFieldName = null;
XContentParser.Token token = parser.nextToken();
assert token == XContentParser.Token.START_OBJECT;
while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
if (token == XContentParser.Token.FIELD_NAME) {
currentFieldName = parser.currentName();
} else if (token.isValue()) {
if ("test".equals(currentFieldName)) {
test = parser.text();
} else {
throw new ElasticsearchParseException("Unrecognized config key: {}", currentFieldName);
}
} else {
throw new ElasticsearchParseException("Unrecognized config key: {}", currentFieldName);
}
}
// asserts for tests
assert customSettings != null;
assert TEST_SETTING.get(customSettings) != null;
}
public String getTestConfig() {
return test;
return TEST_SETTING.get(customSettings);
}
}