Package org.elasticsearch.test.transport

Class CapturingTransport

java.lang.Object

org.elasticsearch.test.transport.CapturingTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, Transport

public class CapturingTransport
extends java.lang.Object
implements Transport

A transport class that doesn't send anything but rather captures all requests for inspection from tests

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CapturingTransport.CapturedRequest

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

Transport.Connection

Field Summary

Fields inherited from interface org.elasticsearch.transport.Transport

TRANSPORT_TCP_COMPRESS

Constructor Summary

Constructors

Constructor	Description
CapturingTransport()

Method Summary

Modifier and Type	Method	Description
void	addLifecycleListener(LifecycleListener listener)
TransportAddress[]	addressesFromString(java.lang.String address, int perAddressLimit)
BoundTransportAddress	boundAddress()
CapturingTransport.CapturedRequest[]	capturedRequests()	returns all requests captured so far.
java.util.Map<java.lang.String,java.util.List<CapturingTransport.CapturedRequest>>	capturedRequestsByTargetNode()	returns all requests captured so far, grouped by target node.
void	clear()	clears captured requests
void	close()
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, CheckedBiConsumer<Transport.Connection,ConnectionProfile,java.io.IOException> connectionValidator)
void	disconnectFromNode(DiscoveryNode node)
CapturingTransport.CapturedRequest[]	getCapturedRequestsAndClear()	Returns all requests captured so far.
java.util.Map<java.lang.String,java.util.List<CapturingTransport.CapturedRequest>>	getCapturedRequestsByTargetNodeAndClear()	Returns all requests captured so far, grouped by target node.
Transport.Connection	getConnection(DiscoveryNode node)
java.util.List<java.lang.String>	getLocalAddresses()
TransportStats	getStats()
void	handleError(long requestId, 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
void	handleResponse(long requestId, TransportResponse response)	simulate a response for the given requestId
Lifecycle.State	lifecycleState()
long	newRequestId()
boolean	nodeConnected(DiscoveryNode node)
Transport.Connection	openConnection(DiscoveryNode node, ConnectionProfile profile)
java.util.Map<java.lang.String,BoundTransportAddress>	profileBoundAddresses()
void	removeLifecycleListener(LifecycleListener listener)
void	setTransportService(TransportService transportService)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.Transport

getInFlightRequestBreaker

Constructor Detail

CapturingTransport

public CapturingTransport()

Method Detail

capturedRequests

public CapturingTransport.CapturedRequest[] capturedRequests()

returns all requests captured so far. Doesn't clear the captured request list. See clear()

getCapturedRequestsAndClear

public CapturingTransport.CapturedRequest[] getCapturedRequestsAndClear()

Returns all requests captured so far. This method does clear the captured requests list. If you do not want the captured requests list cleared, use capturedRequests().

Returns:

the captured requests

capturedRequestsByTargetNode

public java.util.Map<java.lang.String,java.util.List<CapturingTransport.CapturedRequest>> capturedRequestsByTargetNode()

returns all requests captured so far, grouped by target node. Doesn't clear the captured request list. See clear()

getCapturedRequestsByTargetNodeAndClear

public java.util.Map<java.lang.String,java.util.List<CapturingTransport.CapturedRequest>> getCapturedRequestsByTargetNodeAndClear()

Returns all requests captured so far, grouped by target node. This method does clear the captured request list. If you do not want the captured requests list cleared, use capturedRequestsByTargetNode().

Returns:

the captured requests grouped by target node

clear

public void clear()

clears captured requests

handleResponse

public void handleResponse(long requestId,
                           TransportResponse 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,
                        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

openConnection

public Transport.Connection openConnection(DiscoveryNode node,
                                           ConnectionProfile profile)
                                    throws java.io.IOException

Specified by:

openConnection in interface Transport

Throws:

java.io.IOException

getStats

public TransportStats getStats()

Specified by:

getStats in interface Transport

setTransportService

public void setTransportService(TransportService transportService)

Specified by:

setTransportService in interface Transport

boundAddress

public BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface Transport

profileBoundAddresses

public java.util.Map<java.lang.String,BoundTransportAddress> profileBoundAddresses()

Specified by:

profileBoundAddresses in interface Transport

addressesFromString

public TransportAddress[] addressesFromString(java.lang.String address,
                                              int perAddressLimit)
                                       throws java.net.UnknownHostException

Specified by:

addressesFromString in interface Transport

Throws:

java.net.UnknownHostException

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Specified by:

nodeConnected in interface Transport

connectToNode

public void connectToNode(DiscoveryNode node,
                          ConnectionProfile connectionProfile,
                          CheckedBiConsumer<Transport.Connection,ConnectionProfile,java.io.IOException> connectionValidator)
                   throws ConnectTransportException

Specified by:

connectToNode in interface Transport

Throws:

ConnectTransportException

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

Specified by:

disconnectFromNode in interface Transport

lifecycleState

public Lifecycle.State lifecycleState()

Specified by:

lifecycleState in interface LifecycleComponent

addLifecycleListener

public void addLifecycleListener(LifecycleListener listener)

Specified by:

addLifecycleListener in interface LifecycleComponent

removeLifecycleListener

public void removeLifecycleListener(LifecycleListener listener)

Specified by:

removeLifecycleListener in interface LifecycleComponent

start

public void start()

Specified by:

start in interface LifecycleComponent

stop

public void stop()

Specified by:

stop in interface LifecycleComponent

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface Releasable

getLocalAddresses

public java.util.List<java.lang.String> getLocalAddresses()

Specified by:

getLocalAddresses in interface Transport

newRequestId

public long newRequestId()

Specified by:

newRequestId in interface Transport

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Specified by:

getConnection in interface Transport