- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for setWaitForYellowStatus (0.47 sec)
-
src/main/java/org/codelibs/fess/suggest/Suggester.java
.execute() .actionGet(suggestSettings.getIndicesTimeout()); client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(suggestSettings.getClusterTimeout()); created = true; } return created; } catch (final Exception e) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 20.7K bytes - Viewed (3) -
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 Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 22.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
} client.admin() .cluster() .prepareHealth(actualIndex) .setWaitForYellowStatus() .execute() .actionGet(settings.getClusterTimeout()); } if (empty) { client.admin() .indices()
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 15.6K 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); if (searchEngineClient.copyDocIndex(fromIndex, toIndex, replaceAliases) && replaceAliases
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 18K 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(); } catch (final Exception e) {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
client.admin() .cluster() .prepareHealth(fessConfig.getIndexDocumentUpdateIndex()) .setWaitForYellowStatus() .execute() .actionGet(fessConfig.getIndexIndicesTimeout()); final GetIndexResponse response = client.admin()
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0)