Package org.elasticsearch.transport

Class ConnectionProfile

java.lang.Object

org.elasticsearch.transport.ConnectionProfile

public final class ConnectionProfile
extends java.lang.Object

A connection profile describes how many connection are established to specific node for each of the available request types. (TransportRequestOptions.Type). This allows to tailor a connection towards a specific usage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConnectionProfile.Builder	A builder to build a new ConnectionProfile

Method Summary

Modifier and Type	Method	Description
static ConnectionProfile	buildDefaultConnectionProfile(Settings settings)	Builds a default connection profile based on the provided settings.
static ConnectionProfile	buildSingleChannelProfile(TransportRequestOptions.Type channelType)	Builds a connection profile that is dedicated to a single channel type.
static ConnectionProfile	buildSingleChannelProfile(TransportRequestOptions.Type channelType, org.elasticsearch.common.unit.TimeValue connectTimeout, org.elasticsearch.common.unit.TimeValue handshakeTimeout, org.elasticsearch.common.unit.TimeValue pingInterval, java.lang.Boolean compressionEnabled)	Builds a connection profile that is dedicated to a single channel type.
java.lang.Boolean	getCompressionEnabled()	Returns boolean indicating if compression is enabled or null if no explicit compression is set on this profile.
org.elasticsearch.common.unit.TimeValue	getConnectTimeout()	Returns the connect timeout or null if no explicit timeout is set on this profile.
org.elasticsearch.common.unit.TimeValue	getHandshakeTimeout()	Returns the handshake timeout or null if no explicit timeout is set on this profile.
int	getNumConnections()	Returns the total number of connections for this profile
int	getNumConnectionsPerType(TransportRequestOptions.Type type)	Returns the number of connections per type for this profile.
org.elasticsearch.common.unit.TimeValue	getPingInterval()	Returns the ping interval or null if no explicit ping interval is set on this profile.
static ConnectionProfile	resolveConnectionProfile(ConnectionProfile profile, ConnectionProfile fallbackProfile)	takes a ConnectionProfile resolves it to a fully specified (i.e., no nulls) profile

Methods inherited from class java.lang.Object

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

Method Details

resolveConnectionProfile

public static ConnectionProfile resolveConnectionProfile(@Nullable
ConnectionProfile profile,
ConnectionProfile fallbackProfile)

takes a ConnectionProfile resolves it to a fully specified (i.e., no nulls) profile

buildDefaultConnectionProfile

public static ConnectionProfile buildDefaultConnectionProfile(Settings settings)

Builds a default connection profile based on the provided settings.

Parameters:

settings - to build the connection profile from

Returns:

the connection profile

buildSingleChannelProfile

public static ConnectionProfile buildSingleChannelProfile(TransportRequestOptions.Type channelType)

Builds a connection profile that is dedicated to a single channel type. Use this when opening single use connections

buildSingleChannelProfile

public static ConnectionProfile buildSingleChannelProfile(TransportRequestOptions.Type channelType,
@Nullable
org.elasticsearch.common.unit.TimeValue connectTimeout,
@Nullable
org.elasticsearch.common.unit.TimeValue handshakeTimeout,
@Nullable
org.elasticsearch.common.unit.TimeValue pingInterval,
@Nullable
java.lang.Boolean compressionEnabled)

Builds a connection profile that is dedicated to a single channel type. Allows passing connection and handshake timeouts and compression settings.

getConnectTimeout

public org.elasticsearch.common.unit.TimeValue getConnectTimeout()

Returns the connect timeout or null if no explicit timeout is set on this profile.

getHandshakeTimeout

public org.elasticsearch.common.unit.TimeValue getHandshakeTimeout()

Returns the handshake timeout or null if no explicit timeout is set on this profile.

getPingInterval

public org.elasticsearch.common.unit.TimeValue getPingInterval()

Returns the ping interval or null if no explicit ping interval is set on this profile.

getCompressionEnabled

public java.lang.Boolean getCompressionEnabled()

Returns boolean indicating if compression is enabled or null if no explicit compression is set on this profile.

getNumConnections

public int getNumConnections()

Returns the total number of connections for this profile

getNumConnectionsPerType

public int getNumConnectionsPerType(TransportRequestOptions.Type type)

Returns the number of connections per type for this profile. This might return a count that is shared with other types such that the sum of all connections per type might be higher than getNumConnections(). For instance if TransportRequestOptions.Type.BULK shares connections with TransportRequestOptions.Type.REG they will return both the same number of connections from this method but the connections are not distinct.