Package org.opensearch.test.transport

Class MockTransport

java.lang.Object

org.opensearch.test.transport.StubbableTransport

org.opensearch.test.transport.MockTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.opensearch.common.component.LifecycleComponent, org.opensearch.common.lease.Releasable, org.opensearch.transport.Transport

Direct Known Subclasses:

CapturingTransport, DisruptableMockTransport

public class MockTransport
extends StubbableTransport

A basic transport implementation that allows to intercept requests that have been sent

Nested Class Summary

Nested classes/interfaces inherited from class org.opensearch.test.transport.StubbableTransport

StubbableTransport.OpenConnectionBehavior, StubbableTransport.RequestHandlingBehavior<Request extends org.opensearch.transport.TransportRequest>, StubbableTransport.SendRequestBehavior, StubbableTransport.WrappedConnection

Nested classes/interfaces inherited from interface org.opensearch.transport.Transport

org.opensearch.transport.Transport.Connection, org.opensearch.transport.Transport.RequestHandlers, org.opensearch.transport.Transport.ResponseContext<T extends org.opensearch.transport.TransportResponse>, org.opensearch.transport.Transport.ResponseHandlers

Constructor Summary

Constructors

Constructor	Description
MockTransport()

Method Summary

Modifier and Type	Method	Description
org.opensearch.transport.Transport.Connection	createConnection(org.opensearch.cluster.node.DiscoveryNode node)
org.opensearch.transport.TransportService	createTransportService(org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.transport.TransportInterceptor interceptor, java.util.function.Function<org.opensearch.common.transport.BoundTransportAddress,org.opensearch.cluster.node.DiscoveryNode> localNodeFactory, org.opensearch.common.settings.ClusterSettings clusterSettings, java.util.Set<java.lang.String> taskHeaders)
void	handleError(long requestId, org.opensearch.transport.TransportException e)	simulate an error for the given requestId, unlike handleLocalError(long, Throwable) and handleRemoteError(long, Throwable), the provided exception will not be wrapped but will be delivered to the transport layer as is
void	handleLocalError(long requestId, java.lang.Throwable t)	simulate a local error for the given requestId, will be wrapped by a SendRequestTransportException
void	handleRemoteError(long requestId, java.lang.Throwable t)	simulate a remote error for the given requestId, will be wrapped by a RemoteTransportException
<Response extends org.opensearch.transport.TransportResponse> void	handleResponse(long requestId, Response response)	simulate a response for the given requestId
protected void	onSendRequest(long requestId, java.lang.String action, org.opensearch.transport.TransportRequest request, org.opensearch.cluster.node.DiscoveryNode node)
void	setMessageListener(org.opensearch.transport.TransportMessageListener listener)
protected org.opensearch.common.io.stream.NamedWriteableRegistry	writeableRegistry()

Methods inherited from class org.opensearch.test.transport.StubbableTransport

addLifecycleListener, addressesFromString, boundAddress, close, getDefaultSeedAddresses, getRequestHandlers, getResponseHandlers, getStats, lifecycleState, openConnection, profileBoundAddresses, removeLifecycleListener, setDefaultConnectBehavior, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opensearch.transport.Transport

isSecure, registerRequestHandler, setSlowLogThreshold

Constructor Details

MockTransport

public MockTransport()

Method Details

createTransportService

public org.opensearch.transport.TransportService createTransportService(org.opensearch.common.settings.Settings settings, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.transport.TransportInterceptor interceptor, java.util.function.Function<org.opensearch.common.transport.BoundTransportAddress,org.opensearch.cluster.node.DiscoveryNode> localNodeFactory, @Nullable org.opensearch.common.settings.ClusterSettings clusterSettings, java.util.Set<java.lang.String> taskHeaders)

handleResponse

public <Response extends org.opensearch.transport.TransportResponse> void handleResponse(long requestId, Response response)

simulate a response for the given requestId

handleLocalError

public void handleLocalError(long requestId, java.lang.Throwable t)

simulate a local error for the given requestId, will be wrapped by a SendRequestTransportException

Parameters:

requestId - the id corresponding to the captured send request

t - the failure to wrap

handleRemoteError

public void handleRemoteError(long requestId, java.lang.Throwable t)

simulate a remote error for the given requestId, will be wrapped by a RemoteTransportException

Parameters:

requestId - the id corresponding to the captured send request

t - the failure to wrap

handleError

public void handleError(long requestId, org.opensearch.transport.TransportException e)

simulate an error for the given requestId, unlike handleLocalError(long, Throwable) and handleRemoteError(long, Throwable), the provided exception will not be wrapped but will be delivered to the transport layer as is

Parameters:

requestId - the id corresponding to the captured send request

e - the failure

createConnection

public org.opensearch.transport.Transport.Connection createConnection(org.opensearch.cluster.node.DiscoveryNode node)

onSendRequest

protected void onSendRequest(long requestId, java.lang.String action, org.opensearch.transport.TransportRequest request, org.opensearch.cluster.node.DiscoveryNode node)

setMessageListener

public void setMessageListener(org.opensearch.transport.TransportMessageListener listener)

Specified by:

setMessageListener in interface org.opensearch.transport.Transport

Overrides:

setMessageListener in class StubbableTransport

writeableRegistry

protected org.opensearch.common.io.stream.NamedWriteableRegistry writeableRegistry()