Package org.elasticsearch.transport

Class ConnectionProfile.Builder

java.lang.Object

org.elasticsearch.transport.ConnectionProfile.Builder

Enclosing class:

ConnectionProfile

public static class ConnectionProfile.Builder
extends java.lang.Object

A builder to build a new ConnectionProfile

Constructor Summary

Constructors

Constructor	Description
Builder()	create an empty builder
Builder(ConnectionProfile source)	copy constructor, using another profile as a base

Method Summary

Modifier and Type	Method	Description
void	addConnections(int numConnections, TransportRequestOptions.Type... types)	Adds a number of connections for one or more types.
ConnectionProfile	build()	Creates a new ConnectionProfile based on the added connections.
void	setConnectTimeout(TimeValue connectTimeout)	Sets a connect timeout for this connection profile
void	setHandshakeTimeout(TimeValue handshakeTimeout)	Sets a handshake timeout for this connection profile

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

create an empty builder

Builder

public Builder(ConnectionProfile source)

copy constructor, using another profile as a base

Method Detail

setConnectTimeout

public void setConnectTimeout(TimeValue connectTimeout)

Sets a connect timeout for this connection profile

setHandshakeTimeout

public void setHandshakeTimeout(TimeValue handshakeTimeout)

Sets a handshake timeout for this connection profile

addConnections

public void addConnections(int numConnections,
                           TransportRequestOptions.Type... types)

Adds a number of connections for one or more types. Each type can only be added once.

Parameters:

numConnections - the number of connections to use in the pool for the given connection types

types - a set of types that should share the given number of connections

build

public ConnectionProfile build()

Creates a new ConnectionProfile based on the added connections.

Throws:

java.lang.IllegalStateException - if any of the TransportRequestOptions.Type enum is missing