Package org.elasticsearch.transport
Class DisruptableMockTransport
java.lang.Object
org.elasticsearch.test.transport.StubbableTransport
org.elasticsearch.test.transport.MockTransport
org.elasticsearch.transport.DisruptableMockTransport
- All Implemented Interfaces:
Closeable,AutoCloseable,LifecycleComponent,org.elasticsearch.core.Releasable,Transport
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enumResponse type fromgetConnectionStatus(DiscoveryNode)indicating whether, and how, messages should be disrupted on this transport.static interfaceWhen simulating sending requests to another node which might have rebooted, it's not realistic just to drop the action if the node reboots; instead we need to simulate the error response that comes back.Nested classes/interfaces inherited from class org.elasticsearch.test.transport.StubbableTransport
StubbableTransport.OpenConnectionBehavior, StubbableTransport.RequestHandlingBehavior<Request extends TransportRequest>, StubbableTransport.SendRequestBehavior, StubbableTransport.WrappedConnectionNested classes/interfaces inherited from interface org.elasticsearch.transport.Transport
Transport.Connection, Transport.RequestHandlers, Transport.ResponseContext<T extends TransportResponse>, Transport.ResponseHandlers -
Constructor Summary
ConstructorsConstructorDescriptionDisruptableMockTransport(DiscoveryNode localNode, DeterministicTaskQueue deterministicTaskQueue) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddActionBlock(String action) voidcreateTransportService(Settings settings, ThreadPool threadPool, TransportInterceptor interceptor, Function<BoundTransportAddress, DiscoveryNode> localNodeFactory, ClusterSettings clusterSettings, Set<String> taskHeaders) booleanprotected abstract voidprotected abstract DisruptableMockTransport.ConnectionStatusgetConnectionStatus(DiscoveryNode destination) protected abstract Optional<DisruptableMockTransport> protected voidonSendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options, DisruptableMockTransport destinationTransport) voidopenConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> listener) Methods inherited from class org.elasticsearch.test.transport.MockTransport
createConnection, getTransportResponseHandler, handleError, handleLocalError, handleRemoteError, handleResponse, onSendRequest, setMessageListener, writeableRegistryMethods inherited from class org.elasticsearch.test.transport.StubbableTransport
addLifecycleListener, addressesFromString, boundAddress, boundRemoteIngressAddress, close, getDefaultSeedAddresses, getRequestHandlers, getResponseHandlers, getStats, lifecycleState, newNetworkBytesStream, profileBoundAddresses, setDefaultConnectBehavior, start, stopMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.transport.Transport
isSecure, registerRequestHandler, setSlowLogThreshold
-
Constructor Details
-
DisruptableMockTransport
public DisruptableMockTransport(DiscoveryNode localNode, DeterministicTaskQueue deterministicTaskQueue)
-
-
Method Details
-
getConnectionStatus
protected abstract DisruptableMockTransport.ConnectionStatus getConnectionStatus(DiscoveryNode destination) -
getDisruptableMockTransport
protected abstract Optional<DisruptableMockTransport> getDisruptableMockTransport(TransportAddress address) -
execute
-
getLocalNode
-
createTransportService
public TransportService createTransportService(Settings settings, ThreadPool threadPool, TransportInterceptor interceptor, Function<BoundTransportAddress, DiscoveryNode> localNodeFactory, @Nullable ClusterSettings clusterSettings, Set<String> taskHeaders) - Overrides:
createTransportServicein classMockTransport
-
openConnection
public void openConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> listener) - Specified by:
openConnectionin interfaceTransport- Overrides:
openConnectionin classStubbableTransport
-
onSendRequest
protected void onSendRequest(long requestId, String action, TransportRequest request, TransportRequestOptions options, DisruptableMockTransport destinationTransport) -
deliverBlackholedRequests
public boolean deliverBlackholedRequests() -
addActionBlock
-
clearActionBlocks
public void clearActionBlocks()
-