Class RedirectToLocalClusterRemoteClusterClient
java.lang.Object
org.elasticsearch.client.internal.RedirectToLocalClusterRemoteClusterClient
- All Implemented Interfaces:
RemoteClusterClient
public class RedirectToLocalClusterRemoteClusterClient
extends Object
implements RemoteClusterClient
A fake
RemoteClusterClient which just runs actions on the local cluster, like a NodeClient, for use in tests.-
Constructor Summary
ConstructorsConstructorDescriptionRedirectToLocalClusterRemoteClusterClient(ElasticsearchClient localNodeClient) -
Method Summary
Modifier and TypeMethodDescription<Request extends ActionRequest,Response extends TransportResponse>
voidexecute(RemoteClusterActionType<Response> action, Request request, ActionListener<Response> listener) <Request extends ActionRequest,Response extends TransportResponse>
voidexecute(Transport.Connection connection, RemoteClusterActionType<Response> action, Request request, ActionListener<Response> listener) <Request extends ActionRequest>
voidgetConnection(Request request, ActionListener<Transport.Connection> listener)
-
Constructor Details
-
RedirectToLocalClusterRemoteClusterClient
-
-
Method Details
-
execute
public <Request extends ActionRequest,Response extends TransportResponse> void execute(RemoteClusterActionType<Response> action, Request request, ActionListener<Response> listener) - Specified by:
executein interfaceRemoteClusterClient
-
execute
public <Request extends ActionRequest,Response extends TransportResponse> void execute(Transport.Connection connection, RemoteClusterActionType<Response> action, Request request, ActionListener<Response> listener) - Specified by:
executein interfaceRemoteClusterClient
-
getConnection
public <Request extends ActionRequest> void getConnection(Request request, ActionListener<Transport.Connection> listener) - Specified by:
getConnectionin interfaceRemoteClusterClient
-