zoukankan      html  css  js  c++  java
  • elasticSearch6源码分析(5)gateway模块

    1.gateway概述

    The local gateway module stores the cluster state and shard data across full cluster restarts.

    2.gatewaymodule模块

        @Override
        protected void configure() {
            bind(DanglingIndicesState.class).asEagerSingleton();
            bind(GatewayService.class).asEagerSingleton();
            bind(TransportNodesListGatewayMetaState.class).asEagerSingleton();
            bind(TransportNodesListGatewayStartedShards.class).asEagerSingleton();
            bind(LocalAllocateDangledIndices.class).asEagerSingleton();
        }

    2.1 DanglingIndicesState

    /**
     * The dangling indices state is responsible for finding new dangling indices (indices that have
     * their state written on disk, but don't exists in the metadata of the cluster), and importing
     * them into the cluster.
     */

    2.2 GatewayService 

     配置信息

        public static final Setting<Integer> EXPECTED_NODES_SETTING =
            Setting.intSetting("gateway.expected_nodes", -1, -1, Property.NodeScope);
        public static final Setting<Integer> EXPECTED_DATA_NODES_SETTING =
            Setting.intSetting("gateway.expected_data_nodes", -1, -1, Property.NodeScope);
        public static final Setting<Integer> EXPECTED_MASTER_NODES_SETTING =
            Setting.intSetting("gateway.expected_master_nodes", -1, -1, Property.NodeScope);
        public static final Setting<TimeValue> RECOVER_AFTER_TIME_SETTING =
            Setting.positiveTimeSetting("gateway.recover_after_time", TimeValue.timeValueMillis(0), Property.NodeScope);
        public static final Setting<Integer> RECOVER_AFTER_NODES_SETTING =
            Setting.intSetting("gateway.recover_after_nodes", -1, -1, Property.NodeScope);
        public static final Setting<Integer> RECOVER_AFTER_DATA_NODES_SETTING =
            Setting.intSetting("gateway.recover_after_data_nodes", -1, -1, Property.NodeScope);
        public static final Setting<Integer> RECOVER_AFTER_MASTER_NODES_SETTING =
            Setting.intSetting("gateway.recover_after_master_nodes", 0, 0, Property.NodeScope);

    2.3 TransportNodesListGatewayStartedShards

    /**
     * This transport action is used to fetch the shard version from each node during primary allocation in {@link GatewayAllocator}.
     * We use this to find out which node holds the latest shard version and which of them used to be a primary in order to allocate
     * shards after node or cluster restarts.
     */
  • 相关阅读:
    可以使用多少列创建索引?
    如何显示前 50 行?
    简单描述 MySQL 中,索引,主键,唯一索引,联合索引的区别,对数据库的性能有什么影响-从读写两方面?
    实践中如何优化 MySQL ?
    列的字符串类型可以是什么?
    MySQL 里记录货币用什么字段类型好 ?
    什么是通用 SQL 函数?
    对于关系型数据库而言,索引是相当重要的概念?
    为表中得字段选择合适得数据类型?
    SQL 注入漏洞产生的原因?如何防止?
  • 原文地址:https://www.cnblogs.com/davidwang456/p/10109692.html
Copyright © 2011-2022 走看看