Package org.opensearch.test.transport

Class StubbableTransport

java.lang.Object
org.opensearch.test.transport.StubbableTransport
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:
MockTransport
public class StubbableTransport
extends java.lang.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.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.component.LifecycleListener listener)  
    org.opensearch.common.transport.TransportAddress[] addressesFromString​(java.lang.String address)  
    org.opensearch.common.transport.BoundTransportAddress boundAddress()  
    void close()  
    java.util.List<java.lang.String> getDefaultSeedAddresses()  
    org.opensearch.transport.Transport.RequestHandlers getRequestHandlers()  
    org.opensearch.transport.Transport.ResponseHandlers getResponseHandlers()  
    org.opensearch.transport.TransportStats getStats()  
    org.opensearch.common.component.Lifecycle.State lifecycleState()  
    void openConnection​(org.opensearch.cluster.node.DiscoveryNode node, org.opensearch.transport.ConnectionProfile profile, org.opensearch.action.ActionListener<org.opensearch.transport.Transport.Connection> listener)  
    java.util.Map<java.lang.String,​org.opensearch.common.transport.BoundTransportAddress> profileBoundAddresses()  
    void removeLifecycleListener​(org.opensearch.common.component.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.common.transport.BoundTransportAddress boundAddress()
      Specified by:
      boundAddress in interface org.opensearch.transport.Transport

    • addressesFromString

      public org.opensearch.common.transport.TransportAddress[] addressesFromString​(java.lang.String address) throws java.net.UnknownHostException
      Specified by:
      addressesFromString in interface org.opensearch.transport.Transport
      Throws:
      java.net.UnknownHostException

    • getDefaultSeedAddresses

      public java.util.List<java.lang.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.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.component.Lifecycle.State lifecycleState()
      Specified by:
      lifecycleState in interface org.opensearch.common.component.LifecycleComponent

    • addLifecycleListener

      public void addLifecycleListener​(org.opensearch.common.component.LifecycleListener listener)
      Specified by:
      addLifecycleListener in interface org.opensearch.common.component.LifecycleComponent

    • removeLifecycleListener

      public void removeLifecycleListener​(org.opensearch.common.component.LifecycleListener listener)
      Specified by:
      removeLifecycleListener in interface org.opensearch.common.component.LifecycleComponent

    • start

      public void start()
      Specified by:
      start in interface org.opensearch.common.component.LifecycleComponent

    • stop

      public void stop()
      Specified by:
      stop in interface org.opensearch.common.component.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 org.opensearch.common.lease.Releasable

    • profileBoundAddresses

      public java.util.Map<java.lang.String,​org.opensearch.common.transport.BoundTransportAddress> profileBoundAddresses()
      Specified by:
      profileBoundAddresses in interface org.opensearch.transport.Transport