mirror of
https://github.com/elastic/elasticsearch.git
synced 2025-04-25 07:37:19 -04:00
Remove IndexNameExpressionResolver from base classes that don't use it (#120531)
This commit is contained in:
parent
13c75c02f0
commit
39601ed683
229 changed files with 124 additions and 534 deletions
|
@ -16,7 +16,6 @@ import org.elasticsearch.action.support.master.AcknowledgedTransportMasterNodeAc
|
||||||
import org.elasticsearch.cluster.ClusterState;
|
import org.elasticsearch.cluster.ClusterState;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService;
|
import org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService;
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
||||||
|
@ -38,7 +37,6 @@ public class CreateDataStreamTransportAction extends AcknowledgedTransportMaster
|
||||||
ClusterService clusterService,
|
ClusterService clusterService,
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
MetadataCreateDataStreamService metadataCreateDataStreamService,
|
MetadataCreateDataStreamService metadataCreateDataStreamService,
|
||||||
SystemIndices systemIndices
|
SystemIndices systemIndices
|
||||||
) {
|
) {
|
||||||
|
@ -49,7 +47,6 @@ public class CreateDataStreamTransportAction extends AcknowledgedTransportMaster
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CreateDataStreamAction.Request::new,
|
CreateDataStreamAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.metadataCreateDataStreamService = metadataCreateDataStreamService;
|
this.metadataCreateDataStreamService = metadataCreateDataStreamService;
|
||||||
|
|
|
@ -51,6 +51,7 @@ public class DeleteDataStreamTransportAction extends AcknowledgedTransportMaster
|
||||||
|
|
||||||
private static final Logger LOGGER = LogManager.getLogger(DeleteDataStreamTransportAction.class);
|
private static final Logger LOGGER = LogManager.getLogger(DeleteDataStreamTransportAction.class);
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -69,9 +70,9 @@ public class DeleteDataStreamTransportAction extends AcknowledgedTransportMaster
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteDataStreamAction.Request::new,
|
DeleteDataStreamAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -48,7 +48,6 @@ public class MigrateToDataStreamTransportAction extends AcknowledgedTransportMas
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
MigrateToDataStreamAction.Request::new,
|
MigrateToDataStreamAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.metadataMigrateToDataStreamService = new MetadataMigrateToDataStreamService(
|
this.metadataMigrateToDataStreamService = new MetadataMigrateToDataStreamService(
|
||||||
|
|
|
@ -27,6 +27,7 @@ import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
public class ModifyDataStreamsTransportAction extends AcknowledgedTransportMasterNodeAction<ModifyDataStreamsAction.Request> {
|
public class ModifyDataStreamsTransportAction extends AcknowledgedTransportMasterNodeAction<ModifyDataStreamsAction.Request> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -45,9 +46,9 @@ public class ModifyDataStreamsTransportAction extends AcknowledgedTransportMaste
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ModifyDataStreamsAction.Request::new,
|
ModifyDataStreamsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.metadataDataStreamsService = metadataDataStreamsService;
|
this.metadataDataStreamsService = metadataDataStreamsService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -59,7 +59,6 @@ public class PromoteDataStreamTransportAction extends AcknowledgedTransportMaste
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PromoteDataStreamAction.Request::new,
|
PromoteDataStreamAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
|
|
|
@ -62,6 +62,7 @@ public class TransportGetDataStreamsAction extends TransportMasterNodeReadAction
|
||||||
GetDataStreamAction.Response> {
|
GetDataStreamAction.Response> {
|
||||||
|
|
||||||
private static final Logger LOGGER = LogManager.getLogger(TransportGetDataStreamsAction.class);
|
private static final Logger LOGGER = LogManager.getLogger(TransportGetDataStreamsAction.class);
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
private final ClusterSettings clusterSettings;
|
private final ClusterSettings clusterSettings;
|
||||||
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
||||||
|
@ -87,10 +88,10 @@ public class TransportGetDataStreamsAction extends TransportMasterNodeReadAction
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetDataStreamAction.Request::new,
|
GetDataStreamAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetDataStreamAction.Response::new,
|
GetDataStreamAction.Response::new,
|
||||||
transportService.getThreadPool().executor(ThreadPool.Names.MANAGEMENT)
|
transportService.getThreadPool().executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
this.globalRetentionSettings = globalRetentionSettings;
|
this.globalRetentionSettings = globalRetentionSettings;
|
||||||
clusterSettings = clusterService.getClusterSettings();
|
clusterSettings = clusterService.getClusterSettings();
|
||||||
|
|
|
@ -34,6 +34,7 @@ import java.util.List;
|
||||||
public class TransportDeleteDataStreamLifecycleAction extends AcknowledgedTransportMasterNodeAction<
|
public class TransportDeleteDataStreamLifecycleAction extends AcknowledgedTransportMasterNodeAction<
|
||||||
DeleteDataStreamLifecycleAction.Request> {
|
DeleteDataStreamLifecycleAction.Request> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -54,9 +55,9 @@ public class TransportDeleteDataStreamLifecycleAction extends AcknowledgedTransp
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteDataStreamLifecycleAction.Request::new,
|
DeleteDataStreamLifecycleAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.metadataDataStreamsService = metadataDataStreamsService;
|
this.metadataDataStreamsService = metadataDataStreamsService;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -44,6 +44,7 @@ public class TransportExplainDataStreamLifecycleAction extends TransportMasterNo
|
||||||
ExplainDataStreamLifecycleAction.Request,
|
ExplainDataStreamLifecycleAction.Request,
|
||||||
ExplainDataStreamLifecycleAction.Response> {
|
ExplainDataStreamLifecycleAction.Response> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DataStreamLifecycleErrorStore errorStore;
|
private final DataStreamLifecycleErrorStore errorStore;
|
||||||
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
||||||
|
|
||||||
|
@ -64,10 +65,10 @@ public class TransportExplainDataStreamLifecycleAction extends TransportMasterNo
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ExplainDataStreamLifecycleAction.Request::new,
|
ExplainDataStreamLifecycleAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ExplainDataStreamLifecycleAction.Response::new,
|
ExplainDataStreamLifecycleAction.Response::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.errorStore = dataLifecycleServiceErrorStore;
|
this.errorStore = dataLifecycleServiceErrorStore;
|
||||||
this.globalRetentionSettings = globalRetentionSettings;
|
this.globalRetentionSettings = globalRetentionSettings;
|
||||||
}
|
}
|
||||||
|
|
|
@ -41,6 +41,7 @@ public class TransportGetDataStreamLifecycleAction extends TransportMasterNodeRe
|
||||||
GetDataStreamLifecycleAction.Request,
|
GetDataStreamLifecycleAction.Request,
|
||||||
GetDataStreamLifecycleAction.Response> {
|
GetDataStreamLifecycleAction.Response> {
|
||||||
private final ClusterSettings clusterSettings;
|
private final ClusterSettings clusterSettings;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
private final DataStreamGlobalRetentionSettings globalRetentionSettings;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -59,11 +60,11 @@ public class TransportGetDataStreamLifecycleAction extends TransportMasterNodeRe
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetDataStreamLifecycleAction.Request::new,
|
GetDataStreamLifecycleAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetDataStreamLifecycleAction.Response::new,
|
GetDataStreamLifecycleAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
clusterSettings = clusterService.getClusterSettings();
|
clusterSettings = clusterService.getClusterSettings();
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.globalRetentionSettings = globalRetentionSettings;
|
this.globalRetentionSettings = globalRetentionSettings;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -56,7 +56,6 @@ public class TransportGetDataStreamLifecycleStatsAction extends TransportMasterN
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetDataStreamLifecycleStatsAction.Request::new,
|
GetDataStreamLifecycleStatsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetDataStreamLifecycleStatsAction.Response::new,
|
GetDataStreamLifecycleStatsAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -34,6 +34,7 @@ import java.util.List;
|
||||||
*/
|
*/
|
||||||
public class TransportPutDataStreamLifecycleAction extends AcknowledgedTransportMasterNodeAction<PutDataStreamLifecycleAction.Request> {
|
public class TransportPutDataStreamLifecycleAction extends AcknowledgedTransportMasterNodeAction<PutDataStreamLifecycleAction.Request> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -54,9 +55,9 @@ public class TransportPutDataStreamLifecycleAction extends AcknowledgedTransport
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutDataStreamLifecycleAction.Request::new,
|
PutDataStreamLifecycleAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.metadataDataStreamsService = metadataDataStreamsService;
|
this.metadataDataStreamsService = metadataDataStreamsService;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -33,6 +33,7 @@ import java.util.List;
|
||||||
*/
|
*/
|
||||||
public class TransportDeleteDataStreamOptionsAction extends AcknowledgedTransportMasterNodeAction<DeleteDataStreamOptionsAction.Request> {
|
public class TransportDeleteDataStreamOptionsAction extends AcknowledgedTransportMasterNodeAction<DeleteDataStreamOptionsAction.Request> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -53,9 +54,9 @@ public class TransportDeleteDataStreamOptionsAction extends AcknowledgedTranspor
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteDataStreamOptionsAction.Request::new,
|
DeleteDataStreamOptionsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.metadataDataStreamsService = metadataDataStreamsService;
|
this.metadataDataStreamsService = metadataDataStreamsService;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -38,6 +38,7 @@ public class TransportGetDataStreamOptionsAction extends TransportMasterNodeRead
|
||||||
GetDataStreamOptionsAction.Request,
|
GetDataStreamOptionsAction.Request,
|
||||||
GetDataStreamOptionsAction.Response> {
|
GetDataStreamOptionsAction.Response> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -56,10 +57,10 @@ public class TransportGetDataStreamOptionsAction extends TransportMasterNodeRead
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetDataStreamOptionsAction.Request::new,
|
GetDataStreamOptionsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetDataStreamOptionsAction.Response::new,
|
GetDataStreamOptionsAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -33,6 +33,7 @@ import java.util.List;
|
||||||
*/
|
*/
|
||||||
public class TransportPutDataStreamOptionsAction extends AcknowledgedTransportMasterNodeAction<PutDataStreamOptionsAction.Request> {
|
public class TransportPutDataStreamOptionsAction extends AcknowledgedTransportMasterNodeAction<PutDataStreamOptionsAction.Request> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -53,9 +54,9 @@ public class TransportPutDataStreamOptionsAction extends AcknowledgedTransportMa
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutDataStreamOptionsAction.Request::new,
|
PutDataStreamOptionsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.metadataDataStreamsService = metadataDataStreamsService;
|
this.metadataDataStreamsService = metadataDataStreamsService;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -73,7 +73,6 @@ public class TransportDeleteDatabaseConfigurationAction extends TransportMasterN
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
AcknowledgedResponse::readFrom,
|
AcknowledgedResponse::readFrom,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -75,7 +75,6 @@ public class TransportPutDatabaseConfigurationAction extends TransportMasterNode
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
AcknowledgedResponse::readFrom,
|
AcknowledgedResponse::readFrom,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -267,7 +267,6 @@ public class TransportMasterNodeActionIT extends ESIntegTestCase {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
TestRequest::new,
|
TestRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
threadPool.generic()
|
threadPool.generic()
|
||||||
);
|
);
|
||||||
|
|
|
@ -75,7 +75,6 @@ public class TransportClusterAllocationExplainAction extends TransportMasterNode
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterAllocationExplainRequest::new,
|
ClusterAllocationExplainRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterAllocationExplainResponse::new,
|
ClusterAllocationExplainResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -57,7 +57,6 @@ public class TransportDeleteDesiredBalanceAction extends TransportMasterNodeActi
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DesiredBalanceRequest::new,
|
DesiredBalanceRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -65,7 +65,6 @@ public class TransportGetAllocationStatsAction extends TransportMasterNodeReadAc
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
TransportGetAllocationStatsAction.Request::new,
|
TransportGetAllocationStatsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
TransportGetAllocationStatsAction.Response::new,
|
TransportGetAllocationStatsAction.Response::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -68,7 +68,6 @@ public class TransportGetDesiredBalanceAction extends TransportMasterNodeReadAct
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DesiredBalanceRequest::new,
|
DesiredBalanceRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
DesiredBalanceResponse::from,
|
DesiredBalanceResponse::from,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -83,7 +83,6 @@ public class TransportAddVotingConfigExclusionsAction extends TransportMasterNod
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
AddVotingConfigExclusionsRequest::new,
|
AddVotingConfigExclusionsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -65,7 +65,6 @@ public class TransportClearVotingConfigExclusionsAction extends TransportMasterN
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClearVotingConfigExclusionsRequest::new,
|
ClearVotingConfigExclusionsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -56,7 +56,6 @@ public class TransportDeleteDesiredNodesAction extends TransportMasterNodeAction
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
AcknowledgedRequest.Plain::new,
|
AcknowledgedRequest.Plain::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -43,7 +43,6 @@ public class TransportGetDesiredNodesAction extends TransportMasterNodeReadActio
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetDesiredNodesAction.Request::new,
|
GetDesiredNodesAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetDesiredNodesAction.Response::new,
|
GetDesiredNodesAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -64,7 +64,6 @@ public class TransportUpdateDesiredNodesAction extends TransportMasterNodeAction
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
UpdateDesiredNodesRequest::new,
|
UpdateDesiredNodesRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
UpdateDesiredNodesResponse::new,
|
UpdateDesiredNodesResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -53,6 +53,7 @@ public class TransportClusterHealthAction extends TransportMasterNodeReadAction<
|
||||||
public static final ActionType<ClusterHealthResponse> TYPE = new ActionType<ClusterHealthResponse>(NAME);
|
public static final ActionType<ClusterHealthResponse> TYPE = new ActionType<ClusterHealthResponse>(NAME);
|
||||||
private static final Logger logger = LogManager.getLogger(TransportClusterHealthAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportClusterHealthAction.class);
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final AllocationService allocationService;
|
private final AllocationService allocationService;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -72,11 +73,11 @@ public class TransportClusterHealthAction extends TransportMasterNodeReadAction<
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterHealthRequest::new,
|
ClusterHealthRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterHealthResponse::new,
|
ClusterHealthResponse::new,
|
||||||
// fork to management since the health computation can become expensive for large cluster states.
|
// fork to management since the health computation can become expensive for large cluster states.
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.allocationService = allocationService;
|
this.allocationService = allocationService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -78,7 +78,6 @@ public class TransportGetFeatureUpgradeStatusAction extends TransportMasterNodeA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetFeatureUpgradeStatusRequest::new,
|
GetFeatureUpgradeStatusRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetFeatureUpgradeStatusResponse::new,
|
GetFeatureUpgradeStatusResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -63,7 +63,6 @@ public class TransportPostFeatureUpgradeAction extends TransportMasterNodeAction
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PostFeatureUpgradeRequest::new,
|
PostFeatureUpgradeRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PostFeatureUpgradeResponse::new,
|
PostFeatureUpgradeResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -73,7 +73,6 @@ public class TransportPrevalidateNodeRemovalAction extends TransportMasterNodeRe
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PrevalidateNodeRemovalRequest::new,
|
PrevalidateNodeRemovalRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PrevalidateNodeRemovalResponse::new,
|
PrevalidateNodeRemovalResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -82,7 +82,6 @@ public final class TransportCleanupRepositoryAction extends TransportMasterNodeA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CleanupRepositoryRequest::readFrom,
|
CleanupRepositoryRequest::readFrom,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CleanupRepositoryResponse::new,
|
CleanupRepositoryResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -54,7 +54,6 @@ public class TransportDeleteRepositoryAction extends AcknowledgedTransportMaster
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteRepositoryRequest::new,
|
DeleteRepositoryRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.repositoriesService = repositoriesService;
|
this.repositoriesService = repositoriesService;
|
||||||
|
|
|
@ -46,7 +46,6 @@ public class TransportGetRepositoriesAction extends TransportMasterNodeReadActio
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetRepositoriesRequest::new,
|
GetRepositoriesRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetRepositoriesResponse::new,
|
GetRepositoriesResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -54,7 +54,6 @@ public class TransportPutRepositoryAction extends AcknowledgedTransportMasterNod
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutRepositoryRequest::new,
|
PutRepositoryRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.repositoriesService = repositoriesService;
|
this.repositoriesService = repositoriesService;
|
||||||
|
|
|
@ -48,7 +48,6 @@ public class TransportVerifyRepositoryAction extends TransportMasterNodeAction<V
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
VerifyRepositoryRequest::new,
|
VerifyRepositoryRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
VerifyRepositoryResponse::new,
|
VerifyRepositoryResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -74,7 +74,6 @@ public class TransportClusterRerouteAction extends TransportMasterNodeAction<Clu
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterRerouteRequest::new,
|
ClusterRerouteRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterRerouteResponse::new,
|
ClusterRerouteResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -71,7 +71,6 @@ public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAct
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterUpdateSettingsRequest::new,
|
ClusterUpdateSettingsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterUpdateSettingsResponse::new,
|
ClusterUpdateSettingsResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -44,6 +44,7 @@ public class TransportClusterSearchShardsAction extends TransportMasterNodeReadA
|
||||||
public static final ActionType<ClusterSearchShardsResponse> TYPE = new ActionType<>("indices:admin/shards/search_shards");
|
public static final ActionType<ClusterSearchShardsResponse> TYPE = new ActionType<>("indices:admin/shards/search_shards");
|
||||||
|
|
||||||
private final IndicesService indicesService;
|
private final IndicesService indicesService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public TransportClusterSearchShardsAction(
|
public TransportClusterSearchShardsAction(
|
||||||
|
@ -61,11 +62,11 @@ public class TransportClusterSearchShardsAction extends TransportMasterNodeReadA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterSearchShardsRequest::new,
|
ClusterSearchShardsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterSearchShardsResponse::new,
|
ClusterSearchShardsResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.SEARCH_COORDINATION)
|
threadPool.executor(ThreadPool.Names.SEARCH_COORDINATION)
|
||||||
);
|
);
|
||||||
this.indicesService = indicesService;
|
this.indicesService = indicesService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -50,7 +50,6 @@ public final class TransportCloneSnapshotAction extends AcknowledgedTransportMas
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CloneSnapshotRequest::new,
|
CloneSnapshotRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.snapshotsService = snapshotsService;
|
this.snapshotsService = snapshotsService;
|
||||||
|
|
|
@ -49,7 +49,6 @@ public class TransportCreateSnapshotAction extends TransportMasterNodeAction<Cre
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CreateSnapshotRequest::new,
|
CreateSnapshotRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CreateSnapshotResponse::new,
|
CreateSnapshotResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -50,7 +50,6 @@ public class TransportDeleteSnapshotAction extends AcknowledgedTransportMasterNo
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteSnapshotRequest::new,
|
DeleteSnapshotRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.snapshotsService = snapshotsService;
|
this.snapshotsService = snapshotsService;
|
||||||
|
|
|
@ -54,7 +54,6 @@ public class TransportResetFeatureStateAction extends TransportMasterNodeAction<
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ResetFeatureStateRequest::fromStream,
|
ResetFeatureStateRequest::fromStream,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ResetFeatureStateResponse::new,
|
ResetFeatureStateResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -46,7 +46,6 @@ public class TransportSnapshottableFeaturesAction extends TransportMasterNodeAct
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetSnapshottableFeaturesRequest::new,
|
GetSnapshottableFeaturesRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetSnapshottableFeaturesResponse::new,
|
GetSnapshottableFeaturesResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -123,7 +123,6 @@ public class TransportGetSnapshotsAction extends TransportMasterNodeAction<GetSn
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetSnapshotsRequest::new,
|
GetSnapshotsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetSnapshotsResponse::new,
|
GetSnapshotsResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT) // see [NOTE ON THREADING]
|
threadPool.executor(ThreadPool.Names.MANAGEMENT) // see [NOTE ON THREADING]
|
||||||
);
|
);
|
||||||
|
|
|
@ -60,7 +60,6 @@ public class TransportGetShardSnapshotAction extends TransportMasterNodeAction<G
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetShardSnapshotRequest::new,
|
GetShardSnapshotRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetShardSnapshotResponse::new,
|
GetShardSnapshotResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -47,7 +47,6 @@ public class TransportRestoreSnapshotAction extends TransportMasterNodeAction<Re
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
RestoreSnapshotRequest::new,
|
RestoreSnapshotRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
RestoreSnapshotResponse::new,
|
RestoreSnapshotResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.SNAPSHOT_META)
|
threadPool.executor(ThreadPool.Names.SNAPSHOT_META)
|
||||||
);
|
);
|
||||||
|
|
|
@ -91,7 +91,6 @@ public class TransportSnapshotsStatusAction extends TransportMasterNodeAction<Sn
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
SnapshotsStatusRequest::new,
|
SnapshotsStatusRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
SnapshotsStatusResponse::new,
|
SnapshotsStatusResponse::new,
|
||||||
// building the response is somewhat expensive for large snapshots, so we fork.
|
// building the response is somewhat expensive for large snapshots, so we fork.
|
||||||
threadPool.executor(ThreadPool.Names.SNAPSHOT_META)
|
threadPool.executor(ThreadPool.Names.SNAPSHOT_META)
|
||||||
|
|
|
@ -49,6 +49,8 @@ public class TransportClusterStateAction extends TransportMasterNodeReadAction<C
|
||||||
|
|
||||||
private static final Logger logger = LogManager.getLogger(TransportClusterStateAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportClusterStateAction.class);
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public TransportClusterStateAction(
|
public TransportClusterStateAction(
|
||||||
TransportService transportService,
|
TransportService transportService,
|
||||||
|
@ -65,10 +67,10 @@ public class TransportClusterStateAction extends TransportMasterNodeReadAction<C
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ClusterStateRequest::new,
|
ClusterStateRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
ClusterStateResponse::new,
|
ClusterStateResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -45,7 +45,6 @@ public class TransportDeleteStoredScriptAction extends AcknowledgedTransportMast
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteStoredScriptRequest::new,
|
DeleteStoredScriptRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
|
@ -41,7 +41,6 @@ public class TransportGetStoredScriptAction extends TransportMasterNodeReadActio
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetStoredScriptRequest::new,
|
GetStoredScriptRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetStoredScriptResponse::new,
|
GetStoredScriptResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -47,7 +47,6 @@ public class TransportPutStoredScriptAction extends AcknowledgedTransportMasterN
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutStoredScriptRequest::new,
|
PutStoredScriptRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.scriptService = scriptService;
|
this.scriptService = scriptService;
|
||||||
|
|
|
@ -50,7 +50,6 @@ public class TransportPendingClusterTasksAction extends TransportMasterNodeReadA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PendingClusterTasksRequest::new,
|
PendingClusterTasksRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PendingClusterTasksResponse::new,
|
PendingClusterTasksResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -64,6 +64,7 @@ public class TransportIndicesAliasesAction extends TransportMasterNodeAction<Ind
|
||||||
private static final Logger logger = LogManager.getLogger(TransportIndicesAliasesAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportIndicesAliasesAction.class);
|
||||||
|
|
||||||
private final MetadataIndexAliasesService indexAliasesService;
|
private final MetadataIndexAliasesService indexAliasesService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final RequestValidators<IndicesAliasesRequest> requestValidators;
|
private final RequestValidators<IndicesAliasesRequest> requestValidators;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -85,11 +86,11 @@ public class TransportIndicesAliasesAction extends TransportMasterNodeAction<Ind
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
IndicesAliasesRequest::new,
|
IndicesAliasesRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
IndicesAliasesResponse::new,
|
IndicesAliasesResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexAliasesService = indexAliasesService;
|
this.indexAliasesService = indexAliasesService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.requestValidators = Objects.requireNonNull(requestValidators);
|
this.requestValidators = Objects.requireNonNull(requestValidators);
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -46,6 +46,7 @@ public class TransportCloseIndexAction extends TransportMasterNodeAction<CloseIn
|
||||||
private static final Logger logger = LogManager.getLogger(TransportCloseIndexAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportCloseIndexAction.class);
|
||||||
|
|
||||||
private final MetadataIndexStateService indexStateService;
|
private final MetadataIndexStateService indexStateService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DestructiveOperations destructiveOperations;
|
private final DestructiveOperations destructiveOperations;
|
||||||
private volatile boolean closeIndexEnabled;
|
private volatile boolean closeIndexEnabled;
|
||||||
public static final Setting<Boolean> CLUSTER_INDICES_CLOSE_ENABLE_SETTING = Setting.boolSetting(
|
public static final Setting<Boolean> CLUSTER_INDICES_CLOSE_ENABLE_SETTING = Setting.boolSetting(
|
||||||
|
@ -74,11 +75,11 @@ public class TransportCloseIndexAction extends TransportMasterNodeAction<CloseIn
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CloseIndexRequest::new,
|
CloseIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CloseIndexResponse::new,
|
CloseIndexResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexStateService = indexStateService;
|
this.indexStateService = indexStateService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.destructiveOperations = destructiveOperations;
|
this.destructiveOperations = destructiveOperations;
|
||||||
this.closeIndexEnabled = CLUSTER_INDICES_CLOSE_ENABLE_SETTING.get(settings);
|
this.closeIndexEnabled = CLUSTER_INDICES_CLOSE_ENABLE_SETTING.get(settings);
|
||||||
clusterSettings.addSettingsUpdateConsumer(CLUSTER_INDICES_CLOSE_ENABLE_SETTING, this::setCloseIndexEnabled);
|
clusterSettings.addSettingsUpdateConsumer(CLUSTER_INDICES_CLOSE_ENABLE_SETTING, this::setCloseIndexEnabled);
|
||||||
|
|
|
@ -102,7 +102,6 @@ public final class AutoCreateAction extends ActionType<CreateIndexResponse> {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CreateIndexRequest::new,
|
CreateIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CreateIndexResponse::new,
|
CreateIndexResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -68,7 +68,6 @@ public class TransportCreateIndexAction extends TransportMasterNodeAction<Create
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CreateIndexRequest::new,
|
CreateIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CreateIndexResponse::new,
|
CreateIndexResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -73,7 +73,6 @@ public class TransportDeleteDanglingIndexAction extends AcknowledgedTransportMas
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteDanglingIndexRequest::new,
|
DeleteDanglingIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
threadPool.executor(ThreadPool.Names.GENERIC)
|
threadPool.executor(ThreadPool.Names.GENERIC)
|
||||||
);
|
);
|
||||||
this.settings = settings;
|
this.settings = settings;
|
||||||
|
|
|
@ -42,6 +42,7 @@ public class TransportDeleteIndexAction extends AcknowledgedTransportMasterNodeA
|
||||||
private static final Logger logger = LogManager.getLogger(TransportDeleteIndexAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportDeleteIndexAction.class);
|
||||||
|
|
||||||
private final MetadataDeleteIndexService deleteIndexService;
|
private final MetadataDeleteIndexService deleteIndexService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DestructiveOperations destructiveOperations;
|
private final DestructiveOperations destructiveOperations;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -61,10 +62,10 @@ public class TransportDeleteIndexAction extends AcknowledgedTransportMasterNodeA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteIndexRequest::new,
|
DeleteIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.deleteIndexService = deleteIndexService;
|
this.deleteIndexService = deleteIndexService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.destructiveOperations = destructiveOperations;
|
this.destructiveOperations = destructiveOperations;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -18,7 +18,6 @@ import org.elasticsearch.action.support.master.AcknowledgedTransportMasterNodeAc
|
||||||
import org.elasticsearch.cluster.ClusterState;
|
import org.elasticsearch.cluster.ClusterState;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.cluster.metadata.MetadataMappingService;
|
import org.elasticsearch.cluster.metadata.MetadataMappingService;
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
||||||
|
@ -46,7 +45,6 @@ public class TransportAutoPutMappingAction extends AcknowledgedTransportMasterNo
|
||||||
final ThreadPool threadPool,
|
final ThreadPool threadPool,
|
||||||
final MetadataMappingService metadataMappingService,
|
final MetadataMappingService metadataMappingService,
|
||||||
final ActionFilters actionFilters,
|
final ActionFilters actionFilters,
|
||||||
final IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
final SystemIndices systemIndices
|
final SystemIndices systemIndices
|
||||||
) {
|
) {
|
||||||
super(
|
super(
|
||||||
|
@ -56,7 +54,6 @@ public class TransportAutoPutMappingAction extends AcknowledgedTransportMasterNo
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutMappingRequest::new,
|
PutMappingRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.metadataMappingService = metadataMappingService;
|
this.metadataMappingService = metadataMappingService;
|
||||||
|
|
|
@ -53,6 +53,7 @@ public class TransportPutMappingAction extends AcknowledgedTransportMasterNodeAc
|
||||||
private static final Logger logger = LogManager.getLogger(TransportPutMappingAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportPutMappingAction.class);
|
||||||
|
|
||||||
private final MetadataMappingService metadataMappingService;
|
private final MetadataMappingService metadataMappingService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final RequestValidators<PutMappingRequest> requestValidators;
|
private final RequestValidators<PutMappingRequest> requestValidators;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
|
@ -74,10 +75,10 @@ public class TransportPutMappingAction extends AcknowledgedTransportMasterNodeAc
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutMappingRequest::new,
|
PutMappingRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.metadataMappingService = metadataMappingService;
|
this.metadataMappingService = metadataMappingService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.requestValidators = Objects.requireNonNull(requestValidators);
|
this.requestValidators = Objects.requireNonNull(requestValidators);
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
|
@ -39,6 +39,7 @@ public class TransportOpenIndexAction extends TransportMasterNodeAction<OpenInde
|
||||||
private static final Logger logger = LogManager.getLogger(TransportOpenIndexAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportOpenIndexAction.class);
|
||||||
|
|
||||||
private final MetadataIndexStateService indexStateService;
|
private final MetadataIndexStateService indexStateService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DestructiveOperations destructiveOperations;
|
private final DestructiveOperations destructiveOperations;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -58,11 +59,11 @@ public class TransportOpenIndexAction extends TransportMasterNodeAction<OpenInde
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
OpenIndexRequest::new,
|
OpenIndexRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
OpenIndexResponse::new,
|
OpenIndexResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexStateService = indexStateService;
|
this.indexStateService = indexStateService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.destructiveOperations = destructiveOperations;
|
this.destructiveOperations = destructiveOperations;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -46,6 +46,7 @@ public class TransportAddIndexBlockAction extends TransportMasterNodeAction<AddI
|
||||||
private static final Logger logger = LogManager.getLogger(TransportAddIndexBlockAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportAddIndexBlockAction.class);
|
||||||
|
|
||||||
private final MetadataIndexStateService indexStateService;
|
private final MetadataIndexStateService indexStateService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final DestructiveOperations destructiveOperations;
|
private final DestructiveOperations destructiveOperations;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -65,11 +66,11 @@ public class TransportAddIndexBlockAction extends TransportMasterNodeAction<AddI
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
AddIndexBlockRequest::new,
|
AddIndexBlockRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
AddIndexBlockResponse::new,
|
AddIndexBlockResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexStateService = indexStateService;
|
this.indexStateService = indexStateService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.destructiveOperations = destructiveOperations;
|
this.destructiveOperations = destructiveOperations;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -76,6 +76,7 @@ public class TransportRolloverAction extends TransportMasterNodeAction<RolloverR
|
||||||
|
|
||||||
private static final Logger logger = LogManager.getLogger(TransportRolloverAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportRolloverAction.class);
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final Client client;
|
private final Client client;
|
||||||
private final MasterServiceTaskQueue<RolloverTask> rolloverTaskQueue;
|
private final MasterServiceTaskQueue<RolloverTask> rolloverTaskQueue;
|
||||||
private final MetadataDataStreamsService metadataDataStreamsService;
|
private final MetadataDataStreamsService metadataDataStreamsService;
|
||||||
|
@ -129,10 +130,10 @@ public class TransportRolloverAction extends TransportMasterNodeAction<RolloverR
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
RolloverRequest::new,
|
RolloverRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
RolloverResponse::new,
|
RolloverResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.client = client;
|
this.client = client;
|
||||||
this.rolloverTaskQueue = clusterService.createTaskQueue(
|
this.rolloverTaskQueue = clusterService.createTaskQueue(
|
||||||
"rollover",
|
"rollover",
|
||||||
|
|
|
@ -39,6 +39,7 @@ public class TransportGetSettingsAction extends TransportMasterNodeReadAction<Ge
|
||||||
|
|
||||||
private final SettingsFilter settingsFilter;
|
private final SettingsFilter settingsFilter;
|
||||||
private final IndexScopedSettings indexScopedSettings;
|
private final IndexScopedSettings indexScopedSettings;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public TransportGetSettingsAction(
|
public TransportGetSettingsAction(
|
||||||
|
@ -57,12 +58,12 @@ public class TransportGetSettingsAction extends TransportMasterNodeReadAction<Ge
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetSettingsRequest::new,
|
GetSettingsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetSettingsResponse::new,
|
GetSettingsResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
this.settingsFilter = settingsFilter;
|
this.settingsFilter = settingsFilter;
|
||||||
this.indexScopedSettings = indexedScopedSettings;
|
this.indexScopedSettings = indexedScopedSettings;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -50,6 +50,7 @@ public class TransportUpdateSettingsAction extends AcknowledgedTransportMasterNo
|
||||||
private static final Logger logger = LogManager.getLogger(TransportUpdateSettingsAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportUpdateSettingsAction.class);
|
||||||
|
|
||||||
private final MetadataUpdateSettingsService updateSettingsService;
|
private final MetadataUpdateSettingsService updateSettingsService;
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final SystemIndices systemIndices;
|
private final SystemIndices systemIndices;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -69,10 +70,10 @@ public class TransportUpdateSettingsAction extends AcknowledgedTransportMasterNo
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
UpdateSettingsRequest::new,
|
UpdateSettingsRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.updateSettingsService = updateSettingsService;
|
this.updateSettingsService = updateSettingsService;
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.systemIndices = systemIndices;
|
this.systemIndices = systemIndices;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -68,6 +68,7 @@ public class TransportIndicesShardStoresAction extends TransportMasterNodeReadAc
|
||||||
|
|
||||||
private static final Logger logger = LogManager.getLogger(TransportIndicesShardStoresAction.class);
|
private static final Logger logger = LogManager.getLogger(TransportIndicesShardStoresAction.class);
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
private final NodeClient client;
|
private final NodeClient client;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
@ -86,10 +87,10 @@ public class TransportIndicesShardStoresAction extends TransportMasterNodeReadAc
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
IndicesShardStoresRequest::new,
|
IndicesShardStoresRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
IndicesShardStoresResponse::new,
|
IndicesShardStoresResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
this.client = client;
|
this.client = client;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -87,7 +87,6 @@ public class TransportResizeAction extends TransportMasterNodeAction<ResizeReque
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
ResizeRequest::new,
|
ResizeRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CreateIndexResponse::new,
|
CreateIndexResponse::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -57,16 +57,7 @@ public class TransportDeleteComponentTemplateAction extends AcknowledgedTranspor
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver
|
IndexNameExpressionResolver indexNameExpressionResolver
|
||||||
) {
|
) {
|
||||||
super(
|
super(TYPE.name(), transportService, clusterService, threadPool, actionFilters, Request::new, EsExecutors.DIRECT_EXECUTOR_SERVICE);
|
||||||
TYPE.name(),
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
Request::new,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
|
||||||
);
|
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -56,16 +56,7 @@ public class TransportDeleteComposableIndexTemplateAction extends AcknowledgedTr
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver
|
IndexNameExpressionResolver indexNameExpressionResolver
|
||||||
) {
|
) {
|
||||||
super(
|
super(TYPE.name(), transportService, clusterService, threadPool, actionFilters, Request::new, EsExecutors.DIRECT_EXECUTOR_SERVICE);
|
||||||
TYPE.name(),
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
Request::new,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
|
||||||
);
|
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -53,7 +53,6 @@ public class TransportDeleteIndexTemplateAction extends AcknowledgedTransportMas
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteIndexTemplateRequest::new,
|
DeleteIndexTemplateRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
|
|
|
@ -56,7 +56,6 @@ public class TransportPutComponentTemplateAction extends AcknowledgedTransportMa
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutComponentTemplateAction.Request::new,
|
PutComponentTemplateAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
|
|
|
@ -65,16 +65,7 @@ public class TransportPutComposableIndexTemplateAction extends AcknowledgedTrans
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver
|
IndexNameExpressionResolver indexNameExpressionResolver
|
||||||
) {
|
) {
|
||||||
super(
|
super(TYPE.name(), transportService, clusterService, threadPool, actionFilters, Request::new, EsExecutors.DIRECT_EXECUTOR_SERVICE);
|
||||||
TYPE.name(),
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
Request::new,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
|
||||||
);
|
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -61,7 +61,6 @@ public class TransportPutIndexTemplateAction extends AcknowledgedTransportMaster
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutIndexTemplateRequest::new,
|
PutIndexTemplateRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.indexTemplateService = indexTemplateService;
|
this.indexTemplateService = indexTemplateService;
|
||||||
|
|
|
@ -48,7 +48,6 @@ public class DeletePipelineTransportAction extends AcknowledgedTransportMasterNo
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeletePipelineRequest::new,
|
DeletePipelineRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.ingestService = ingestService;
|
this.ingestService = ingestService;
|
||||||
|
|
|
@ -21,7 +21,6 @@ import org.elasticsearch.client.internal.node.NodeClient;
|
||||||
import org.elasticsearch.cluster.ClusterState;
|
import org.elasticsearch.cluster.ClusterState;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
||||||
import org.elasticsearch.ingest.IngestService;
|
import org.elasticsearch.ingest.IngestService;
|
||||||
import org.elasticsearch.injection.guice.Inject;
|
import org.elasticsearch.injection.guice.Inject;
|
||||||
|
@ -44,7 +43,6 @@ public class PutPipelineTransportAction extends AcknowledgedTransportMasterNodeA
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
TransportService transportService,
|
TransportService transportService,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
IngestService ingestService,
|
IngestService ingestService,
|
||||||
NodeClient client
|
NodeClient client
|
||||||
) {
|
) {
|
||||||
|
@ -55,7 +53,6 @@ public class PutPipelineTransportAction extends AcknowledgedTransportMasterNodeA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutPipelineRequest::new,
|
PutPipelineRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
// This client is only used to perform an internal implementation detail,
|
// This client is only used to perform an internal implementation detail,
|
||||||
|
|
|
@ -10,7 +10,6 @@
|
||||||
package org.elasticsearch.action.support.master;
|
package org.elasticsearch.action.support.master;
|
||||||
|
|
||||||
import org.elasticsearch.action.support.ActionFilters;
|
import org.elasticsearch.action.support.ActionFilters;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
import org.elasticsearch.common.io.stream.Writeable;
|
import org.elasticsearch.common.io.stream.Writeable;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
|
@ -32,20 +31,9 @@ public abstract class AcknowledgedTransportMasterNodeAction<Request extends Mast
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
super(
|
super(actionName, transportService, clusterService, threadPool, actionFilters, request, AcknowledgedResponse::readFrom, executor);
|
||||||
actionName,
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
request,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
AcknowledgedResponse::readFrom,
|
|
||||||
executor
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
protected AcknowledgedTransportMasterNodeAction(
|
protected AcknowledgedTransportMasterNodeAction(
|
||||||
|
@ -56,7 +44,6 @@ public abstract class AcknowledgedTransportMasterNodeAction<Request extends Mast
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
super(
|
super(
|
||||||
|
@ -67,7 +54,6 @@ public abstract class AcknowledgedTransportMasterNodeAction<Request extends Mast
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
request,
|
request,
|
||||||
indexNameExpressionResolver,
|
|
||||||
AcknowledgedResponse::readFrom,
|
AcknowledgedResponse::readFrom,
|
||||||
executor
|
executor
|
||||||
);
|
);
|
||||||
|
|
|
@ -22,7 +22,6 @@ import org.elasticsearch.cluster.ClusterStateObserver;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
|
@ -64,7 +63,6 @@ public abstract class TransportMasterNodeAction<Request extends MasterNodeReques
|
||||||
protected final ThreadPool threadPool;
|
protected final ThreadPool threadPool;
|
||||||
protected final TransportService transportService;
|
protected final TransportService transportService;
|
||||||
protected final ClusterService clusterService;
|
protected final ClusterService clusterService;
|
||||||
protected final IndexNameExpressionResolver indexNameExpressionResolver;
|
|
||||||
|
|
||||||
private final Writeable.Reader<Response> responseReader;
|
private final Writeable.Reader<Response> responseReader;
|
||||||
|
|
||||||
|
@ -77,22 +75,10 @@ public abstract class TransportMasterNodeAction<Request extends MasterNodeReques
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Writeable.Reader<Response> response,
|
Writeable.Reader<Response> response,
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
this(
|
this(actionName, true, transportService, clusterService, threadPool, actionFilters, request, response, executor);
|
||||||
actionName,
|
|
||||||
true,
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
request,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
response,
|
|
||||||
executor
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
protected TransportMasterNodeAction(
|
protected TransportMasterNodeAction(
|
||||||
|
@ -103,7 +89,6 @@ public abstract class TransportMasterNodeAction<Request extends MasterNodeReques
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Writeable.Reader<Response> response,
|
Writeable.Reader<Response> response,
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
|
@ -111,7 +96,6 @@ public abstract class TransportMasterNodeAction<Request extends MasterNodeReques
|
||||||
this.transportService = transportService;
|
this.transportService = transportService;
|
||||||
this.clusterService = clusterService;
|
this.clusterService = clusterService;
|
||||||
this.threadPool = threadPool;
|
this.threadPool = threadPool;
|
||||||
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
|
||||||
this.executor = executor;
|
this.executor = executor;
|
||||||
this.responseReader = response;
|
this.responseReader = response;
|
||||||
}
|
}
|
||||||
|
|
|
@ -11,7 +11,6 @@ package org.elasticsearch.action.support.master;
|
||||||
|
|
||||||
import org.elasticsearch.action.ActionResponse;
|
import org.elasticsearch.action.ActionResponse;
|
||||||
import org.elasticsearch.action.support.ActionFilters;
|
import org.elasticsearch.action.support.ActionFilters;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
import org.elasticsearch.common.io.stream.Writeable;
|
import org.elasticsearch.common.io.stream.Writeable;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
|
@ -33,22 +32,10 @@ public abstract class TransportMasterNodeReadAction<Request extends MasterNodeRe
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Writeable.Reader<Response> response,
|
Writeable.Reader<Response> response,
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
this(
|
this(actionName, true, transportService, clusterService, threadPool, actionFilters, request, response, executor);
|
||||||
actionName,
|
|
||||||
true,
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
request,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
response,
|
|
||||||
executor
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
protected TransportMasterNodeReadAction(
|
protected TransportMasterNodeReadAction(
|
||||||
|
@ -59,22 +46,10 @@ public abstract class TransportMasterNodeReadAction<Request extends MasterNodeRe
|
||||||
ThreadPool threadPool,
|
ThreadPool threadPool,
|
||||||
ActionFilters actionFilters,
|
ActionFilters actionFilters,
|
||||||
Writeable.Reader<Request> request,
|
Writeable.Reader<Request> request,
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
|
||||||
Writeable.Reader<Response> response,
|
Writeable.Reader<Response> response,
|
||||||
Executor executor
|
Executor executor
|
||||||
) {
|
) {
|
||||||
super(
|
super(actionName, canTripCircuitBreaker, transportService, clusterService, threadPool, actionFilters, request, response, executor);
|
||||||
actionName,
|
|
||||||
canTripCircuitBreaker,
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
request,
|
|
||||||
indexNameExpressionResolver,
|
|
||||||
response,
|
|
||||||
executor
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -25,6 +25,8 @@ import org.elasticsearch.transport.TransportService;
|
||||||
public abstract class TransportClusterInfoAction<Request extends ClusterInfoRequest<Request>, Response extends ActionResponse> extends
|
public abstract class TransportClusterInfoAction<Request extends ClusterInfoRequest<Request>, Response extends ActionResponse> extends
|
||||||
TransportMasterNodeReadAction<Request, Response> {
|
TransportMasterNodeReadAction<Request, Response> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
|
|
||||||
public TransportClusterInfoAction(
|
public TransportClusterInfoAction(
|
||||||
String actionName,
|
String actionName,
|
||||||
TransportService transportService,
|
TransportService transportService,
|
||||||
|
@ -42,10 +44,10 @@ public abstract class TransportClusterInfoAction<Request extends ClusterInfoRequ
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
request,
|
request,
|
||||||
indexNameExpressionResolver,
|
|
||||||
response,
|
response,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -125,7 +125,6 @@ public class CompletionPersistentTaskAction {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PersistentTaskResponse::new,
|
PersistentTaskResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.GENERIC)
|
threadPool.executor(ThreadPool.Names.GENERIC)
|
||||||
);
|
);
|
||||||
|
|
|
@ -94,7 +94,6 @@ public class RemovePersistentTaskAction {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PersistentTaskResponse::new,
|
PersistentTaskResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -137,7 +137,6 @@ public class StartPersistentTaskAction {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PersistentTaskResponse::new,
|
PersistentTaskResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.GENERIC)
|
threadPool.executor(ThreadPool.Names.GENERIC)
|
||||||
);
|
);
|
||||||
|
|
|
@ -124,7 +124,6 @@ public class UpdatePersistentTaskStatusAction {
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
PersistentTaskResponse::new,
|
PersistentTaskResponse::new,
|
||||||
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
threadPool.executor(ThreadPool.Names.MANAGEMENT)
|
||||||
);
|
);
|
||||||
|
|
|
@ -3669,7 +3669,6 @@ public final class SnapshotsService extends AbstractLifecycleComponent implement
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
UpdateIndexShardSnapshotStatusRequest::new,
|
UpdateIndexShardSnapshotStatusRequest::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
in -> ActionResponse.Empty.INSTANCE,
|
in -> ActionResponse.Empty.INSTANCE,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -257,7 +257,6 @@ public class TransportMasterNodeActionTests extends ESTestCase {
|
||||||
threadPool,
|
threadPool,
|
||||||
new ActionFilters(new HashSet<>()),
|
new ActionFilters(new HashSet<>()),
|
||||||
Request::new,
|
Request::new,
|
||||||
TestIndexNameExpressionResolver.newInstance(),
|
|
||||||
Response::new,
|
Response::new,
|
||||||
executor
|
executor
|
||||||
);
|
);
|
||||||
|
@ -300,7 +299,6 @@ public class TransportMasterNodeActionTests extends ESTestCase {
|
||||||
threadPool,
|
threadPool,
|
||||||
new ActionFilters(new HashSet<>()),
|
new ActionFilters(new HashSet<>()),
|
||||||
ClusterUpdateSettingsRequest::new,
|
ClusterUpdateSettingsRequest::new,
|
||||||
TestIndexNameExpressionResolver.newInstance(),
|
|
||||||
Response::new,
|
Response::new,
|
||||||
executor
|
executor
|
||||||
);
|
);
|
||||||
|
|
|
@ -133,7 +133,6 @@ public class InternalOrPrivateSettingsPlugin extends Plugin implements ActionPlu
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
UpdateInternalOrPrivateAction.Request::new,
|
UpdateInternalOrPrivateAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
UpdateInternalOrPrivateAction.Response::new,
|
UpdateInternalOrPrivateAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -2464,7 +2464,6 @@ public class SnapshotResiliencyTests extends ESTestCase {
|
||||||
threadPool,
|
threadPool,
|
||||||
metadataMappingService,
|
metadataMappingService,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EmptySystemIndices.INSTANCE
|
EmptySystemIndices.INSTANCE
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
|
|
|
@ -35,14 +35,7 @@ public class AnalyticsUsageTransportAction extends XPackUsageFeatureTransportAct
|
||||||
IndexNameExpressionResolver indexNameExpressionResolver,
|
IndexNameExpressionResolver indexNameExpressionResolver,
|
||||||
Client client
|
Client client
|
||||||
) {
|
) {
|
||||||
super(
|
super(XPackUsageFeatureAction.ANALYTICS.name(), transportService, clusterService, threadPool, actionFilters);
|
||||||
XPackUsageFeatureAction.ANALYTICS.name(),
|
|
||||||
transportService,
|
|
||||||
clusterService,
|
|
||||||
threadPool,
|
|
||||||
actionFilters,
|
|
||||||
indexNameExpressionResolver
|
|
||||||
);
|
|
||||||
this.client = client;
|
this.client = client;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -56,7 +56,6 @@ public class TransportDeleteAutoscalingPolicyAction extends AcknowledgedTranspor
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteAutoscalingPolicyAction.Request::new,
|
DeleteAutoscalingPolicyAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
|
@ -67,7 +67,6 @@ public class TransportGetAutoscalingCapacityAction extends TransportMasterNodeAc
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetAutoscalingCapacityAction.Request::new,
|
GetAutoscalingCapacityAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetAutoscalingCapacityAction.Response::new,
|
GetAutoscalingCapacityAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -50,7 +50,6 @@ public class TransportGetAutoscalingPolicyAction extends TransportMasterNodeActi
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetAutoscalingPolicyAction.Request::new,
|
GetAutoscalingPolicyAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetAutoscalingPolicyAction.Response::new,
|
GetAutoscalingPolicyAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -84,7 +84,6 @@ public class TransportPutAutoscalingPolicyAction extends AcknowledgedTransportMa
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutAutoscalingPolicyAction.Request::new,
|
PutAutoscalingPolicyAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.policyValidator = policyValidator;
|
this.policyValidator = policyValidator;
|
||||||
|
|
|
@ -44,7 +44,7 @@ public class CCRUsageTransportAction extends XPackUsageFeatureTransportAction {
|
||||||
Settings settings,
|
Settings settings,
|
||||||
XPackLicenseState licenseState
|
XPackLicenseState licenseState
|
||||||
) {
|
) {
|
||||||
super(XPackUsageFeatureAction.CCR.name(), transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver);
|
super(XPackUsageFeatureAction.CCR.name(), transportService, clusterService, threadPool, actionFilters);
|
||||||
this.settings = settings;
|
this.settings = settings;
|
||||||
this.licenseState = licenseState;
|
this.licenseState = licenseState;
|
||||||
}
|
}
|
||||||
|
|
|
@ -48,7 +48,6 @@ public class TransportActivateAutoFollowPatternAction extends AcknowledgedTransp
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
Request::new,
|
Request::new,
|
||||||
resolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
|
@ -53,7 +53,6 @@ public class TransportCcrStatsAction extends TransportMasterNodeAction<CcrStatsA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
CcrStatsAction.Request::new,
|
CcrStatsAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
CcrStatsAction.Response::new,
|
CcrStatsAction.Response::new,
|
||||||
threadPool.executor(Ccr.CCR_THREAD_POOL_NAME)
|
threadPool.executor(Ccr.CCR_THREAD_POOL_NAME)
|
||||||
);
|
);
|
||||||
|
|
|
@ -45,7 +45,6 @@ public class TransportDeleteAutoFollowPatternAction extends AcknowledgedTranspor
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
DeleteAutoFollowPatternAction.Request::new,
|
DeleteAutoFollowPatternAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
|
@ -38,6 +38,8 @@ import java.util.Optional;
|
||||||
|
|
||||||
public class TransportFollowInfoAction extends TransportMasterNodeReadAction<FollowInfoAction.Request, FollowInfoAction.Response> {
|
public class TransportFollowInfoAction extends TransportMasterNodeReadAction<FollowInfoAction.Request, FollowInfoAction.Response> {
|
||||||
|
|
||||||
|
private final IndexNameExpressionResolver indexNameExpressionResolver;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public TransportFollowInfoAction(
|
public TransportFollowInfoAction(
|
||||||
TransportService transportService,
|
TransportService transportService,
|
||||||
|
@ -53,10 +55,10 @@ public class TransportFollowInfoAction extends TransportMasterNodeReadAction<Fol
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
FollowInfoAction.Request::new,
|
FollowInfoAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
FollowInfoAction.Response::new,
|
FollowInfoAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
this.indexNameExpressionResolver = indexNameExpressionResolver;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -48,7 +48,6 @@ public class TransportGetAutoFollowPatternAction extends TransportMasterNodeRead
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
GetAutoFollowPatternAction.Request::new,
|
GetAutoFollowPatternAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
GetAutoFollowPatternAction.Response::new,
|
GetAutoFollowPatternAction.Response::new,
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
|
|
|
@ -51,7 +51,6 @@ public class TransportPauseFollowAction extends AcknowledgedTransportMasterNodeA
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PauseFollowAction.Request::new,
|
PauseFollowAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.persistentTasksService = persistentTasksService;
|
this.persistentTasksService = persistentTasksService;
|
||||||
|
|
|
@ -71,7 +71,6 @@ public class TransportPutAutoFollowPatternAction extends AcknowledgedTransportMa
|
||||||
threadPool,
|
threadPool,
|
||||||
actionFilters,
|
actionFilters,
|
||||||
PutAutoFollowPatternAction.Request::new,
|
PutAutoFollowPatternAction.Request::new,
|
||||||
indexNameExpressionResolver,
|
|
||||||
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
EsExecutors.DIRECT_EXECUTOR_SERVICE
|
||||||
);
|
);
|
||||||
this.client = client;
|
this.client = client;
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show more
Loading…
Add table
Add a link
Reference in a new issue