Package org.elasticsearch.test.transport

Class MockTransportService.DelegateTransport

java.lang.Object

org.elasticsearch.test.transport.MockTransportService.DelegateTransport

All Implemented Interfaces:

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

Direct Known Subclasses:

MockTransportService.ClearableTransport

Enclosing class:

MockTransportService

public static class MockTransportService.DelegateTransport
extends java.lang.Object
implements Transport

A pure delegate transport. Can be extracted to a common class if needed in other places in the codebase.

Nested Class Summary

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

Transport.Connection

Field Summary

Fields

Modifier and Type	Field	Description
protected Transport	transport

Fields inherited from interface org.elasticsearch.transport.Transport

TRANSPORT_TCP_COMPRESS

Constructor Summary

Constructors

Constructor	Description
DelegateTransport(Transport transport)

Method Summary

Modifier and Type	Method	Description
void	addLifecycleListener(LifecycleListener listener)
TransportAddress[]	addressesFromString(java.lang.String address, int perAddressLimit)
BoundTransportAddress	boundAddress()
void	close()
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, CheckedBiConsumer<Transport.Connection,ConnectionProfile,java.io.IOException> connectionValidator)
void	disconnectFromNode(DiscoveryNode node)
Transport.Connection	getConnection(DiscoveryNode node)
java.util.List<java.lang.String>	getLocalAddresses()
TransportStats	getStats()
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)
protected void	sendRequest(Transport.Connection connection, long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions options)
void	setTransportService(TransportService service)
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

Field Detail

transport

protected final Transport transport

Constructor Detail

DelegateTransport

public DelegateTransport(Transport transport)

Method Detail

setTransportService

public void setTransportService(TransportService service)

Specified by:

setTransportService in interface Transport

boundAddress

public BoundTransportAddress boundAddress()

Specified by:

boundAddress 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

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

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

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

profileBoundAddresses

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

Specified by:

profileBoundAddresses in interface Transport

sendRequest

protected void sendRequest(Transport.Connection connection,
                           long requestId,
                           java.lang.String action,
                           TransportRequest request,
                           TransportRequestOptions options)
                    throws java.io.IOException

Throws:

java.io.IOException