diff --git a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/shield/SecuredClient.java b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/shield/SecuredClient.java index 8ac4ddd3980..04713390d39 100644 --- a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/shield/SecuredClient.java +++ b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/shield/SecuredClient.java @@ -129,6 +129,10 @@ import org.elasticsearch.action.admin.indices.flush.FlushAction; import org.elasticsearch.action.admin.indices.flush.FlushRequest; import org.elasticsearch.action.admin.indices.flush.FlushRequestBuilder; import org.elasticsearch.action.admin.indices.flush.FlushResponse; +import org.elasticsearch.action.admin.indices.flush.SyncedFlushAction; +import org.elasticsearch.action.admin.indices.flush.SyncedFlushRequest; +import org.elasticsearch.action.admin.indices.flush.SyncedFlushRequestBuilder; +import org.elasticsearch.action.admin.indices.flush.SyncedFlushResponse; import org.elasticsearch.action.admin.indices.forcemerge.ForceMergeAction; import org.elasticsearch.action.admin.indices.forcemerge.ForceMergeRequest; import org.elasticsearch.action.admin.indices.forcemerge.ForceMergeRequestBuilder; @@ -260,6 +264,7 @@ import org.elasticsearch.common.Nullable; import org.elasticsearch.common.Strings; import org.elasticsearch.common.inject.Inject; import org.elasticsearch.common.settings.Settings; +import org.elasticsearch.indices.flush.SyncedFlushService; import org.elasticsearch.threadpool.ThreadPool; /** @@ -791,6 +796,21 @@ public class SecuredClient implements Client { return (new FlushRequestBuilder(this, FlushAction.INSTANCE)).setIndices(indices); } + @Override + public ActionFuture syncedFlush(SyncedFlushRequest syncedFlushRequest) { + return this.execute(SyncedFlushAction.INSTANCE, syncedFlushRequest); + } + + @Override + public void syncedFlush(SyncedFlushRequest syncedFlushRequest, ActionListener actionListener) { + this.execute(SyncedFlushAction.INSTANCE, syncedFlushRequest, actionListener); + } + + @Override + public SyncedFlushRequestBuilder prepareSyncedFlush(String... indices) { + return (new SyncedFlushRequestBuilder(this, SyncedFlushAction.INSTANCE)).setIndices(indices); + } + public void getMappings(GetMappingsRequest request, ActionListener listener) { this.execute(GetMappingsAction.INSTANCE, request, listener); }