Class StubbableTransport

java.lang.Object

org.opensearch.test.transport.StubbableTransport

All Implemented Interfaces:

Closeable, AutoCloseable, org.opensearch.common.lease.Releasable, org.opensearch.common.lifecycle.LifecycleComponent, org.opensearch.transport.Transport

Direct Known Subclasses:

MockTransport

public class StubbableTransport
extends Object
implements org.opensearch.transport.Transport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StubbableTransport.OpenConnectionBehavior
static interface	StubbableTransport.RequestHandlingBehavior<Request extends org.opensearch.transport.TransportRequest>
static interface	StubbableTransport.SendRequestBehavior
class	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.core.transport.TransportResponse>, org.opensearch.transport.Transport.ResponseHandlers

Constructor Summary

Constructors

Constructor	Description
StubbableTransport(org.opensearch.transport.Transport transport)

Method Summary

Modifier and Type	Method	Description
void	addLifecycleListener(org.opensearch.common.lifecycle.LifecycleListener listener)
org.opensearch.core.common.transport.TransportAddress[]	addressesFromString(String address)
org.opensearch.core.common.transport.BoundTransportAddress	boundAddress()
void	close()
List<String>	getDefaultSeedAddresses()
org.opensearch.transport.Transport.RequestHandlers	getRequestHandlers()
org.opensearch.transport.Transport.ResponseHandlers	getResponseHandlers()
org.opensearch.transport.TransportStats	getStats()
org.opensearch.common.lifecycle.Lifecycle.State	lifecycleState()
void	openConnection(org.opensearch.cluster.node.DiscoveryNode node, org.opensearch.transport.ConnectionProfile profile, org.opensearch.core.action.ActionListener<org.opensearch.transport.Transport.Connection> listener)
Map<String, org.opensearch.core.common.transport.BoundTransportAddress>	profileBoundAddresses()
void	removeLifecycleListener(org.opensearch.common.lifecycle.LifecycleListener listener)
boolean	setDefaultConnectBehavior(StubbableTransport.OpenConnectionBehavior openConnectionBehavior)
void	setMessageListener(org.opensearch.transport.TransportMessageListener listener)
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.opensearch.transport.Transport

isSecure, registerRequestHandler, setSlowLogThreshold

Constructor Details

StubbableTransport

public StubbableTransport(org.opensearch.transport.Transport transport)

Method Details

setDefaultConnectBehavior

public boolean setDefaultConnectBehavior(StubbableTransport.OpenConnectionBehavior openConnectionBehavior)

setMessageListener

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

Specified by:

setMessageListener in interface org.opensearch.transport.Transport

boundAddress

public org.opensearch.core.common.transport.BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface org.opensearch.transport.Transport

addressesFromString

public org.opensearch.core.common.transport.TransportAddress[] addressesFromString(String address)
                                                                            throws UnknownHostException

Specified by:

addressesFromString in interface org.opensearch.transport.Transport

Throws:

UnknownHostException

getDefaultSeedAddresses

public List<String> getDefaultSeedAddresses()

Specified by:

getDefaultSeedAddresses in interface org.opensearch.transport.Transport

openConnection

public void openConnection(org.opensearch.cluster.node.DiscoveryNode node,
 org.opensearch.transport.ConnectionProfile profile,
 org.opensearch.core.action.ActionListener<org.opensearch.transport.Transport.Connection> listener)

Specified by:

openConnection in interface org.opensearch.transport.Transport

getStats

public org.opensearch.transport.TransportStats getStats()

Specified by:

getStats in interface org.opensearch.transport.Transport

getResponseHandlers

public org.opensearch.transport.Transport.ResponseHandlers getResponseHandlers()

Specified by:

getResponseHandlers in interface org.opensearch.transport.Transport

getRequestHandlers

public org.opensearch.transport.Transport.RequestHandlers getRequestHandlers()

Specified by:

getRequestHandlers in interface org.opensearch.transport.Transport

lifecycleState

public org.opensearch.common.lifecycle.Lifecycle.State lifecycleState()

Specified by:

lifecycleState in interface org.opensearch.common.lifecycle.LifecycleComponent

addLifecycleListener

public void addLifecycleListener(org.opensearch.common.lifecycle.LifecycleListener listener)

Specified by:

addLifecycleListener in interface org.opensearch.common.lifecycle.LifecycleComponent

removeLifecycleListener

public void removeLifecycleListener(org.opensearch.common.lifecycle.LifecycleListener listener)

Specified by:

removeLifecycleListener in interface org.opensearch.common.lifecycle.LifecycleComponent

start

public void start()

Specified by:

start in interface org.opensearch.common.lifecycle.LifecycleComponent

stop

public void stop()

Specified by:

stop in interface org.opensearch.common.lifecycle.LifecycleComponent

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.opensearch.common.lease.Releasable

profileBoundAddresses

public Map<String, org.opensearch.core.common.transport.BoundTransportAddress> profileBoundAddresses()

Specified by:

profileBoundAddresses in interface org.opensearch.transport.Transport