- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for setWaitForYellowStatus (0.16 seconds)
-
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) {
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 21.6K bytes - Click Count (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();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 22.3K bytes - Click Count (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()Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 15.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
try { searchEngineClient.admin() .cluster() .prepareHealth(toIndex) .setWaitForYellowStatus() .execute(ActionListener.wrap(response -> { try { searchEngineClient.addMapping(docIndex, "doc", toIndex);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 23K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
final String[] indices = targetIndices != null ? targetIndices : new String[0]; final ClusterHealthResponse healthResponse = get(c -> c.admin().cluster().prepareHealth(indices).setWaitForYellowStatus().execute()); if (!healthResponse.isTimedOut()) { onConnectListenerList.forEach(l -> { try { l.onConnect(); } catch (final Exception e) {Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (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()
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 138.6K bytes - Click Count (1)