Class MockStreamNioTransport

java.lang.Object
org.opensearch.common.lifecycle.AbstractLifecycleComponent
org.opensearch.transport.TcpTransport
org.opensearch.transport.nio.MockNioTransport
org.opensearch.transport.nio.MockStreamNioTransport
All Implemented Interfaces:
Closeable, AutoCloseable, org.opensearch.common.lease.Releasable, org.opensearch.common.lifecycle.LifecycleComponent, org.opensearch.transport.Transport
public class MockStreamNioTransport extends MockNioTransport
A specialized MockNioTransport that supports streaming transport channels for testing streaming search. This transport extends MockNioTransport and overrides the inbound handler creation to provide MockNativeMessageHandler which creates mock streaming transport channels when needed.
Opensearch.internal:

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.opensearch.transport.nio.MockNioTransport

    MockNioTransport.MockSocketChannel

    Nested classes/interfaces inherited from class org.opensearch.transport.TcpTransport

    org.opensearch.transport.TcpTransport.HttpRequestOnTransportException, org.opensearch.transport.TcpTransport.NodeChannels, org.opensearch.transport.TcpTransport.ProfileSettings

    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

  • Field Summary

    Fields inherited from class org.opensearch.transport.nio.MockNioTransport

    clientChannelFactory, nioGroup

    Fields inherited from class org.opensearch.transport.TcpTransport

    inboundHandler, networkService, pageCacheRecycler, profileSettings, settings, threadPool, TRANSPORT_WORKER_THREAD_NAME_PREFIX

    Fields inherited from class org.opensearch.common.lifecycle.AbstractLifecycleComponent

    lifecycle

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockStreamNioTransport(org.opensearch.common.settings.Settings settings, org.opensearch.Version version, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.common.network.NetworkService networkService, org.opensearch.common.util.PageCacheRecycler pageCacheRecycler, org.opensearch.core.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.opensearch.core.indices.breaker.CircuitBreakerService circuitBreakerService, org.opensearch.telemetry.tracing.Tracer tracer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.opensearch.transport.InboundHandler
    createInboundHandler(String nodeName, org.opensearch.Version version, String[] features, org.opensearch.transport.StatsTracker statsTracker, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.common.util.BigArrays bigArrays, org.opensearch.transport.OutboundHandler outboundHandler, org.opensearch.core.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.opensearch.transport.TransportHandshaker handshaker, org.opensearch.transport.TransportKeepAlive keepAlive, org.opensearch.transport.Transport.RequestHandlers requestHandlers, org.opensearch.transport.Transport.ResponseHandlers responseHandlers, org.opensearch.telemetry.tracing.Tracer tracer)
     

    Methods inherited from class org.opensearch.transport.nio.MockNioTransport

    bind, doStart, initiateChannel, maybeOverrideConnectionProfile, stopInternal

    Methods inherited from class org.opensearch.transport.TcpTransport

    addressesFromString, bindServer, boundAddress, doClose, doStop, ensureOpen, executeHandshake, getDefaultSeedAddresses, getInflightBreaker, getPageCacheRecycler, getProfileSettings, getRequestHandlers, getResponseHandlers, getStats, getStatsTracker, getThreadPool, getVersion, inboundMessage, inboundMessage, onException, onServerException, openConnection, profileBoundAddresses, readMessageLength, serverAcceptedChannel, setMessageListener, setSlowLogThreshold

    Methods inherited from class org.opensearch.common.lifecycle.AbstractLifecycleComponent

    addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, 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.common.lifecycle.LifecycleComponent

    addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

    Methods inherited from interface org.opensearch.common.lease.Releasable

    close

    Methods inherited from interface org.opensearch.transport.Transport

    isSecure, registerRequestHandler

  • Constructor Details

    • MockStreamNioTransport

      public MockStreamNioTransport(org.opensearch.common.settings.Settings settings, org.opensearch.Version version, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.common.network.NetworkService networkService, org.opensearch.common.util.PageCacheRecycler pageCacheRecycler, org.opensearch.core.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.opensearch.core.indices.breaker.CircuitBreakerService circuitBreakerService, org.opensearch.telemetry.tracing.Tracer tracer)

  • Method Details

    • createInboundHandler

      protected org.opensearch.transport.InboundHandler createInboundHandler(String nodeName, org.opensearch.Version version, String[] features, org.opensearch.transport.StatsTracker statsTracker, org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.common.util.BigArrays bigArrays, org.opensearch.transport.OutboundHandler outboundHandler, org.opensearch.core.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.opensearch.transport.TransportHandshaker handshaker, org.opensearch.transport.TransportKeepAlive keepAlive, org.opensearch.transport.Transport.RequestHandlers requestHandlers, org.opensearch.transport.Transport.ResponseHandlers responseHandlers, org.opensearch.telemetry.tracing.Tracer tracer)
      Overrides:
      createInboundHandler in class org.opensearch.transport.TcpTransport