org.xbib.elasticsearch.transport.netty

Class NettyTransport

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent<org.elasticsearch.transport.Transport>

org.xbib.elasticsearch.transport.netty.NettyTransport

All Implemented Interfaces:

org.elasticsearch.common.component.CloseableComponent, org.elasticsearch.common.component.LifecycleComponent<org.elasticsearch.transport.Transport>, org.elasticsearch.transport.Transport

public class NettyTransport
extends org.elasticsearch.common.component.AbstractLifecycleComponent<org.elasticsearch.transport.Transport>
implements org.elasticsearch.transport.Transport

There are 4 types of connections per node, low/med/high/ping. Low if for batch oriented APIs (like recovery or batch) with high payload that will cause regular request. (like search or single index) to take longer. Med is for the typical search / single doc index. And High for things like cluster state. Ping is reserved for sending out ping requests to other nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NettyTransport.NodeChannels

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

org.elasticsearch.transport.Transport.TransportSettings

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
NettyTransport(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.common.network.NetworkService networkService, org.elasticsearch.common.util.BigArrays bigArrays, org.elasticsearch.Version version)

Method Summary

Methods

Modifier and Type	Method and Description
org.elasticsearch.common.transport.TransportAddress[]	addressesFromString(String address)
boolean	addressSupported(Class<? extends org.elasticsearch.common.transport.TransportAddress> address)
org.elasticsearch.common.transport.BoundTransportAddress	boundAddress()
void	connectToNode(org.elasticsearch.cluster.node.DiscoveryNode node)
void	connectToNode(org.elasticsearch.cluster.node.DiscoveryNode node, boolean light)
void	connectToNodeLight(org.elasticsearch.cluster.node.DiscoveryNode node)
void	disconnectFromNode(org.elasticsearch.cluster.node.DiscoveryNode node)
protected void	doClose()
protected void	doStart()
protected void	doStop()
boolean	nodeConnected(org.elasticsearch.cluster.node.DiscoveryNode node)
void	sendRequest(org.elasticsearch.cluster.node.DiscoveryNode node, long requestId, String action, org.elasticsearch.transport.TransportRequest request, org.elasticsearch.transport.TransportRequestOptions options)
long	serverOpen()
org.elasticsearch.common.settings.Settings	settings()
void	transportServiceAdapter(org.elasticsearch.transport.TransportServiceAdapter service)

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.component.CloseableComponent

close

Constructor Detail

NettyTransport

@Inject
public NettyTransport(org.elasticsearch.common.settings.Settings settings,
                     org.elasticsearch.threadpool.ThreadPool threadPool,
                     org.elasticsearch.common.network.NetworkService networkService,
                     org.elasticsearch.common.util.BigArrays bigArrays,
                     org.elasticsearch.Version version)

Method Detail

settings

public org.elasticsearch.common.settings.Settings settings()

transportServiceAdapter

public void transportServiceAdapter(org.elasticsearch.transport.TransportServiceAdapter service)

Specified by:

transportServiceAdapter in interface org.elasticsearch.transport.Transport

doStart

protected void doStart()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doStart in class org.elasticsearch.common.component.AbstractLifecycleComponent<org.elasticsearch.transport.Transport>

Throws:

org.elasticsearch.ElasticsearchException

doStop

protected void doStop()
               throws org.elasticsearch.ElasticsearchException

Specified by:

doStop in class org.elasticsearch.common.component.AbstractLifecycleComponent<org.elasticsearch.transport.Transport>

Throws:

org.elasticsearch.ElasticsearchException

doClose

protected void doClose()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doClose in class org.elasticsearch.common.component.AbstractLifecycleComponent<org.elasticsearch.transport.Transport>

Throws:

org.elasticsearch.ElasticsearchException

addressesFromString

public org.elasticsearch.common.transport.TransportAddress[] addressesFromString(String address)
                                                                          throws Exception

Specified by:

addressesFromString in interface org.elasticsearch.transport.Transport

Throws:

Exception

addressSupported

public boolean addressSupported(Class<? extends org.elasticsearch.common.transport.TransportAddress> address)

Specified by:

addressSupported in interface org.elasticsearch.transport.Transport

boundAddress

public org.elasticsearch.common.transport.BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface org.elasticsearch.transport.Transport

serverOpen

public long serverOpen()

Specified by:

serverOpen in interface org.elasticsearch.transport.Transport

sendRequest

public void sendRequest(org.elasticsearch.cluster.node.DiscoveryNode node,
               long requestId,
               String action,
               org.elasticsearch.transport.TransportRequest request,
               org.elasticsearch.transport.TransportRequestOptions options)
                 throws IOException,
                        org.elasticsearch.transport.TransportException

Specified by:

sendRequest in interface org.elasticsearch.transport.Transport

Throws:

IOException

org.elasticsearch.transport.TransportException

nodeConnected

public boolean nodeConnected(org.elasticsearch.cluster.node.DiscoveryNode node)

Specified by:

nodeConnected in interface org.elasticsearch.transport.Transport

connectToNodeLight

public void connectToNodeLight(org.elasticsearch.cluster.node.DiscoveryNode node)
                        throws org.elasticsearch.transport.ConnectTransportException

Specified by:

connectToNodeLight in interface org.elasticsearch.transport.Transport

Throws:

org.elasticsearch.transport.ConnectTransportException

connectToNode

public void connectToNode(org.elasticsearch.cluster.node.DiscoveryNode node)

Specified by:

connectToNode in interface org.elasticsearch.transport.Transport

connectToNode

public void connectToNode(org.elasticsearch.cluster.node.DiscoveryNode node,
                 boolean light)

disconnectFromNode

public void disconnectFromNode(org.elasticsearch.cluster.node.DiscoveryNode node)

Specified by:

disconnectFromNode in interface org.elasticsearch.transport.Transport