本文整理汇总了Java中org.elasticsearch.plugins.PluginInfo类的典型用法代码示例。如果您正苦于以下问题:Java PluginInfo类的具体用法?Java PluginInfo怎么用?Java PluginInfo使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PluginInfo类属于org.elasticsearch.plugins包,在下文中一共展示了PluginInfo类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: buildTable
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
private Table buildTable(RestRequest req, ClusterStateResponse state, NodesInfoResponse nodesInfo) {
DiscoveryNodes nodes = state.getState().nodes();
Table table = getTableWithHeader(req);
for (DiscoveryNode node : nodes) {
NodeInfo info = nodesInfo.getNodesMap().get(node.getId());
for (PluginInfo pluginInfo : info.getPlugins().getPluginInfos()) {
table.startRow();
table.addCell(node.getId());
table.addCell(node.getName());
table.addCell(pluginInfo.getName());
table.addCell(pluginInfo.getVersion());
table.addCell(pluginInfo.getDescription());
table.endRow();
}
}
return table;
}
开发者ID:justor,项目名称:elasticsearch_my,代码行数:21,代码来源:RestPluginsAction.java
示例2: toXContent
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
builder.startArray("plugins");
for (PluginInfo pluginInfo : getPluginInfos()) {
pluginInfo.toXContent(builder, params);
}
builder.endArray();
// TODO: not ideal, make a better api for this (e.g. with jar metadata, and so on)
builder.startArray("modules");
for (PluginInfo moduleInfo : getModuleInfos()) {
moduleInfo.toXContent(builder, params);
}
builder.endArray();
return builder;
}
开发者ID:justor,项目名称:elasticsearch_my,代码行数:17,代码来源:PluginsAndModules.java
示例3: readFrom
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public void readFrom(StreamInput in) throws IOException {
counts = Counts.readCounts(in);
int size = in.readVInt();
versions = new HashSet<>(size);
for (; size > 0; size--) {
versions.add(Version.readVersion(in));
}
os = OsStats.readOsStats(in);
process = ProcessStats.readStats(in);
jvm = JvmStats.readJvmStats(in);
fs = FsInfo.Path.readInfoFrom(in);
size = in.readVInt();
plugins = new HashSet<>(size);
for (; size > 0; size--) {
plugins.add(PluginInfo.readFromStream(in));
}
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:22,代码来源:ClusterStatsNodes.java
示例4: readFrom
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public void readFrom(StreamInput in) throws IOException {
if (plugins.isEmpty() == false || modules.isEmpty() == false) {
throw new IllegalStateException("instance is already populated");
}
int plugins_size = in.readInt();
for (int i = 0; i < plugins_size; i++) {
plugins.add(PluginInfo.readFromStream(in));
}
if (in.getVersion().onOrAfter(Version.V_2_2_0)) {
int modules_size = in.readInt();
for (int i = 0; i < modules_size; i++) {
modules.add(PluginInfo.readFromStream(in));
}
}
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:17,代码来源:PluginsAndModules.java
示例5: testPluginLoaded
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Test
public void testPluginLoaded() {
NodesInfoResponse nodesInfoResponse = client().admin().cluster().prepareNodesInfo().clear().setPlugins(true).get();
assertTrue(nodesInfoResponse.getNodes().length != 0);
assertThat(nodesInfoResponse.getNodes()[0].getPlugins().getPluginInfos(), notNullValue());
assertThat(nodesInfoResponse.getNodes()[0].getPlugins().getPluginInfos().size(), not(0));
boolean pluginFound = false;
for (PluginInfo pluginInfo : nodesInfoResponse.getNodes()[0].getPlugins().getPluginInfos()) {
if (pluginInfo.getName().equals("SirenJoinPlugin")) {
pluginFound = true;
break;
}
}
assertThat(pluginFound, is(true));
}
开发者ID:sirensolutions,项目名称:siren-join,代码行数:19,代码来源:SirenJoinPluginTest.java
示例6: testPluginIsLoaded
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
public void testPluginIsLoaded() {
NodesInfoResponse response = client().admin().cluster().prepareNodesInfo().setPlugins(true).get();
for (NodeInfo node : response.getNodes()) {
boolean founded = false;
for (PluginInfo pluginInfo : node.getPlugins().getPluginInfos()) {
if (pluginInfo.getName().equals(AnalysisOpenKoreanTextPlugin.class.getName())) {
founded = true;
}
}
Assert.assertTrue(founded);
}
}
开发者ID:open-korean-text,项目名称:elasticsearch-analysis-openkoreantext,代码行数:13,代码来源:AnalysisOpenKoreanTextPluginTest.java
示例7: checkPluginInstalled
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
private boolean checkPluginInstalled(Client client) {
NodesInfoResponse nodesInfoResponse = client.admin().cluster().prepareNodesInfo().setPlugins(true).get();
for (NodeInfo nodeInfo : nodesInfoResponse.getNodes()) {
for (PluginInfo pluginInfo : nodeInfo.getPlugins().getPluginInfos()) {
if ("memgraph".equals(pluginInfo.getName())) {
return true;
}
}
}
if (config.isErrorOnMissingMemgraphPlugin()) {
throw new MemgraphException("Memgraph plugin cannot be found");
}
LOGGER.warn("Running without the server side Memgraph plugin will be deprecated in the future.");
return false;
}
开发者ID:mware-solutions,项目名称:memory-graph,代码行数:16,代码来源:Elasticsearch5SearchIndex.java
示例8: toXContent
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
builder.startObject(Fields.COUNT);
counts.toXContent(builder, params);
builder.endObject();
builder.startArray(Fields.VERSIONS);
for (Version v : versions) {
builder.value(v.toString());
}
builder.endArray();
builder.startObject(Fields.OS);
os.toXContent(builder, params);
builder.endObject();
builder.startObject(Fields.PROCESS);
process.toXContent(builder, params);
builder.endObject();
builder.startObject(Fields.JVM);
jvm.toXContent(builder, params);
builder.endObject();
builder.field(Fields.FS);
fs.toXContent(builder, params);
builder.startArray(Fields.PLUGINS);
for (PluginInfo pluginInfo : plugins) {
pluginInfo.toXContent(builder, params);
}
builder.endArray();
builder.startObject(Fields.NETWORK_TYPES);
networkTypes.toXContent(builder, params);
builder.endObject();
return builder;
}
开发者ID:justor,项目名称:elasticsearch_my,代码行数:39,代码来源:ClusterStatsNodes.java
示例9: testPluginIsLoaded
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
public void testPluginIsLoaded() throws Exception {
NodesInfoResponse response = client().admin().cluster().prepareNodesInfo().setPlugins(true).get();
for (NodeInfo nodeInfo : response.getNodes()) {
boolean pluginFound = false;
for (PluginInfo pluginInfo : nodeInfo.getPlugins().getPluginInfos()) {
if (pluginInfo.getName().equals(RosetteTextAnalysisPlugin.class.getName())) {
pluginFound = true;
break;
}
}
assertTrue(pluginFound);
}
}
开发者ID:rosette-api,项目名称:rosette-elasticsearch-plugin,代码行数:14,代码来源:RosetteTextAnalysisPluginIT.java
示例10: buildTable
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
private Table buildTable(RestRequest req, ClusterStateResponse state, NodesInfoResponse nodesInfo) {
DiscoveryNodes nodes = state.getState().nodes();
Table table = getTableWithHeader(req);
for (DiscoveryNode node : nodes) {
NodeInfo info = nodesInfo.getNodesMap().get(node.id());
for (PluginInfo pluginInfo : info.getPlugins().getPluginInfos()) {
table.startRow();
table.addCell(node.id());
table.addCell(node.name());
table.addCell(pluginInfo.getName());
table.addCell(pluginInfo.getVersion());
String type;
if (pluginInfo.isSite()) {
if (pluginInfo.isJvm()) {
type = "j/s";
} else {
type = "s";
}
} else {
if (pluginInfo.isJvm()) {
type = "j";
} else {
type = "";
}
}
table.addCell(type);
table.addCell(pluginInfo.getUrl());
table.addCell(pluginInfo.getDescription());
table.endRow();
}
}
return table;
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:37,代码来源:RestPluginsAction.java
示例11: writeTo
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public void writeTo(StreamOutput out) throws IOException {
counts.writeTo(out);
out.writeVInt(versions.size());
for (Version v : versions) Version.writeVersion(v, out);
os.writeTo(out);
process.writeTo(out);
jvm.writeTo(out);
fs.writeTo(out);
out.writeVInt(plugins.size());
for (PluginInfo p : plugins) {
p.writeTo(out);
}
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:15,代码来源:ClusterStatsNodes.java
示例12: toXContent
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
builder.startObject(Fields.COUNT);
counts.toXContent(builder, params);
builder.endObject();
builder.startArray(Fields.VERSIONS);
for (Version v : versions) {
builder.value(v.toString());
}
builder.endArray();
builder.startObject(Fields.OS);
os.toXContent(builder, params);
builder.endObject();
builder.startObject(Fields.PROCESS);
process.toXContent(builder, params);
builder.endObject();
builder.startObject(Fields.JVM);
jvm.toXContent(builder, params);
builder.endObject();
builder.field(Fields.FS);
fs.toXContent(builder, params);
builder.startArray(Fields.PLUGINS);
for (PluginInfo pluginInfo : plugins) {
pluginInfo.toXContent(builder, params);
}
builder.endArray();
return builder;
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:35,代码来源:ClusterStatsNodes.java
示例13: getPluginInfos
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
/**
* Returns an ordered list based on plugins name
*/
public List<PluginInfo> getPluginInfos() {
List<PluginInfo> plugins = new ArrayList<>(this.plugins);
Collections.sort(plugins, new Comparator<PluginInfo>() {
@Override
public int compare(PluginInfo p1, PluginInfo p2) {
return p1.getName().compareTo(p2.getName());
}
});
return plugins;
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:14,代码来源:PluginsAndModules.java
示例14: getModuleInfos
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
/**
* Returns an ordered list based on modules name
*/
public List<PluginInfo> getModuleInfos() {
List<PluginInfo> modules = new ArrayList<>(this.modules);
Collections.sort(modules, new Comparator<PluginInfo>() {
@Override
public int compare(PluginInfo p1, PluginInfo p2) {
return p1.getName().compareTo(p2.getName());
}
});
return modules;
}
开发者ID:baidu,项目名称:Elasticsearch,代码行数:14,代码来源:PluginsAndModules.java
示例15: loadPlugins
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private List<Tuple<PluginInfo, Plugin>> loadPlugins() {
return AccessController.doPrivileged((PrivilegedAction<List<Tuple<PluginInfo, Plugin>>>) () -> {
try {
final Field pluginsField = pluginsService.getClass().getDeclaredField("plugins");
pluginsField.setAccessible(true);
return (List<Tuple<PluginInfo, Plugin>>) pluginsField.get(pluginsService);
} catch (final Exception e) {
throw new ElasticsearchException("Failed to access plugins in PluginsService.", e);
}
});
}
开发者ID:codelibs,项目名称:elasticsearch-analysis-fess,代码行数:13,代码来源:FessAnalysisService.java
示例16: loadClass
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
public Class<?> loadClass(final String className) {
return AccessController.doPrivileged((PrivilegedAction<Class<?>>) () -> {
for (final Tuple<PluginInfo, Plugin> p : plugins) {
final Plugin plugin = p.v2();
try {
return plugin.getClass().getClassLoader().loadClass(className);
} catch (final ClassNotFoundException e) {
// ignore
}
}
return null;
});
}
开发者ID:codelibs,项目名称:elasticsearch-analysis-fess,代码行数:14,代码来源:FessAnalysisService.java
示例17: checkPluginInstalled
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
private boolean checkPluginInstalled(Client client) {
NodesInfoResponse nodesInfoResponse = client.admin().cluster().prepareNodesInfo().setPlugins(true).get();
for (NodeInfo nodeInfo : nodesInfoResponse.getNodes()) {
for (PluginInfo pluginInfo : nodeInfo.getPlugins().getPluginInfos()) {
if ("vertexium".equals(pluginInfo.getName())) {
return true;
}
}
}
if (config.isErrorOnMissingVertexiumPlugin()) {
throw new VertexiumException("Vertexium plugin cannot be found");
}
LOGGER.warn("Running without the server side Vertexium plugin will be deprecated in the future.");
return false;
}
开发者ID:visallo,项目名称:vertexium,代码行数:16,代码来源:Elasticsearch5SearchIndex.java
示例18: testPluginIsLoaded
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
public void testPluginIsLoaded() throws Exception {
NodesInfoResponse response = client().admin().cluster().prepareNodesInfo().setPlugins(true).get();
for (NodeInfo nodeInfo : response.getNodes()) {
boolean pluginFound = false;
for (PluginInfo pluginInfo : nodeInfo.getPlugins().getPluginInfos()) {
if (pluginInfo.getName().equals(AnalysisVietnamesePlugin.class.getName())) {
pluginFound = true;
break;
}
}
assertThat(pluginFound, is(true));
}
}
开发者ID:duydo,项目名称:elasticsearch-analysis-vietnamese,代码行数:14,代码来源:VietnameseAnalysisIntegrationTest.java
示例19: getPluginPermissions
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
/**
* we don't know which codesources belong to which plugin, so just remove the permission from key codebases
* like core, test-framework, etc. this way tests fail if accesscontroller blocks are missing.
*/
@SuppressForbidden(reason = "accesses fully qualified URLs to configure security")
static Map<String,Policy> getPluginPermissions() throws Exception {
List<URL> pluginPolicies = Collections.list(BootstrapForTesting.class.getClassLoader().getResources(PluginInfo.ES_PLUGIN_POLICY));
if (pluginPolicies.isEmpty()) {
return Collections.emptyMap();
}
// compute classpath minus obvious places, all other jars will get the permission.
Set<URL> codebases = new HashSet<>(Arrays.asList(parseClassPathWithSymlinks()));
Set<URL> excluded = new HashSet<>(Arrays.asList(
// es core
Bootstrap.class.getProtectionDomain().getCodeSource().getLocation(),
// es test framework
BootstrapForTesting.class.getProtectionDomain().getCodeSource().getLocation(),
// lucene test framework
LuceneTestCase.class.getProtectionDomain().getCodeSource().getLocation(),
// randomized runner
RandomizedRunner.class.getProtectionDomain().getCodeSource().getLocation(),
// junit library
Assert.class.getProtectionDomain().getCodeSource().getLocation()
));
codebases.removeAll(excluded);
// parse each policy file, with codebase substitution from the classpath
final List<Policy> policies = new ArrayList<>();
for (URL policyFile : pluginPolicies) {
policies.add(Security.readPolicy(policyFile, codebases.toArray(new URL[codebases.size()])));
}
// consult each policy file for those codebases
Map<String,Policy> map = new HashMap<>();
for (URL url : codebases) {
map.put(url.getFile(), new Policy() {
@Override
public boolean implies(ProtectionDomain domain, Permission permission) {
// implements union
for (Policy p : policies) {
if (p.implies(domain, permission)) {
return true;
}
}
return false;
}
});
}
return Collections.unmodifiableMap(map);
}
开发者ID:justor,项目名称:elasticsearch_my,代码行数:52,代码来源:BootstrapForTesting.java
示例20: getPlugins
import org.elasticsearch.plugins.PluginInfo; //导入依赖的package包/类
public Set<PluginInfo> getPlugins() {
return plugins;
}
开发者ID:justor,项目名称:elasticsearch_my,代码行数:4,代码来源:ClusterStatsNodes.java
注:本文中的org.elasticsearch.plugins.PluginInfo类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论