- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for prepareHealth (0.13 sec)
-
src/main/java/org/codelibs/fess/suggest/Suggester.java
.actionGet(suggestSettings.getIndicesTimeout()); client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(suggestSettings.getClusterTimeout()); created = true; } return created; } catch (final Exception e) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 14.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient(); searchEngineClient.admin().cluster().prepareHealth().setWaitForYellowStatus().execute() .actionGet(fessConfig.getIndexHealthTimeout()); final SuggestSettingsBuilder settingsBuilder = SuggestSettings.builder();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 18.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
if (!response.isAcknowledged()) { throw new SuggestSettingsException("Failed to create " + actualIndex + "/" + type + " index.", e); } client.admin().cluster().prepareHealth(actualIndex).setWaitForYellowStatus().execute() .actionGet(settings.getClusterTimeout()); } if (empty) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
try { final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient(); final ClusterHealthResponse response = esClient.admin().cluster().prepareHealth().execute().actionGet(fessConfig.getIndexHealthTimeout()); engineObj.clusterName = response.getClusterName(); engineObj.numberOfNodes = response.getNumberOfNodes();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
if (searchEngineClient.createIndex(docIndex, toIndex, numberOfShards, autoExpandReplicas, resetDictionaries)) { searchEngineClient.admin().cluster().prepareHealth(toIndex).setWaitForYellowStatus().execute(ActionListener.wrap(response -> { searchEngineClient.addMapping(docIndex, "doc", toIndex);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 14K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
} public void setSettings(final Map<String, String> settings) { this.settings = settings; } public String getStatus() { return admin().cluster().prepareHealth().execute().actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout()).getStatus() .name(); } public void setRunner(final OpenSearchRunner runner) { this.runner = runner;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Oct 20 02:08:03 UTC 2024 - 86.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} public void connect() { destroy(); client = createClient(); final ClusterHealthResponse healthResponse = get(c -> c.admin().cluster().prepareHealth(targetIndices).setWaitForYellowStatus().execute()); if (!healthResponse.isTimedOut()) { onConnectListenerList.forEach(l -> { try { l.onConnect();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0)