Java PluginInfo类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了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；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java PopupView类代码示例发布时间：2022-05-22

Java NullLiteralExpr类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18149|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9635|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8161|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8538|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8440|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9360|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8410|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7848|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8395|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7387|2022-11-06

客服电话

电子邮件

Java PluginInfo类代码示例

示例1: buildTable

示例2: toXContent

示例3: readFrom

示例4: readFrom

示例5: testPluginLoaded

示例6: testPluginIsLoaded

示例7: checkPluginInstalled

示例8: toXContent

示例9: testPluginIsLoaded

示例10: buildTable

示例11: writeTo

示例12: toXContent

示例13: getPluginInfos

示例14: getModuleInfos

示例15: loadPlugins

示例16: loadClass

示例17: checkPluginInstalled

示例18: testPluginIsLoaded

示例19: getPluginPermissions

示例20: getPlugins

请发表评论

全部评论

上一篇：

下一篇：

PacktPublishing/Python-Machine-Learning-

MATLAB——文件读写（1）

armancodv/building-energy-model-matlab:

鲁东大学一米网:Win7系统USB驱动器RAM的操

FGRibreau/import-tweets-to-mastodon: How

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053