Package com.linkedin.venice.httpclient

Class HttpClientUtils

java.lang.Object

com.linkedin.venice.httpclient.HttpClientUtils

public class HttpClientUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HttpClientUtils.ClosableHttpAsyncClientWithConnManager

Constructor Summary

Constructors

Constructor	Description
HttpClientUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager	createConnectionManager(int ioThreadNum, int perRoute, int total, int soTimeout, int connectionTimeout, Optional<SSLFactory> sslFactory, Optional<CachedDnsResolver> dnsResolver, Optional<HttpConnectionPoolStats> poolStats)
static org.apache.http.impl.nio.client.CloseableHttpAsyncClient	getMinimalHttpClient(int ioThreadNum, int maxConnPerRoute, int maxConnTotal, int socketTimeout, int connectionTimeout, Optional<SSLFactory> sslFactory, Optional<CachedDnsResolver> dnsResolver, Optional<HttpConnectionPoolStats> poolStats)
static org.apache.http.impl.nio.client.CloseableHttpAsyncClient	getMinimalHttpClient(int ioThreadNum, int maxConnPerRoute, int maxConnTotal, int socketTimeout, int connectionTimeout, Optional<SSLFactory> sslFactory, Optional<CachedDnsResolver> dnsResolver, Optional<HttpConnectionPoolStats> poolStats, boolean isIdleConnectionToServerCleanupEnabled, long idleConnectionCleanupThresholdMins)
static org.apache.http.impl.nio.client.CloseableHttpAsyncClient	getMinimalHttpClient(int maxConnPerRoute, int maxConnTotal, Optional<SSLFactory> sslFactory)	This function is only being used in test cases.
static HttpClientUtils.ClosableHttpAsyncClientWithConnManager	getMinimalHttpClientWithConnManager(int ioThreadNum, int maxConnPerRoute, int maxConnTotal, int socketTimeout, int connectionTimeout, Optional<SSLFactory> sslFactory, Optional<CachedDnsResolver> dnsResolver, Optional<HttpConnectionPoolStats> poolStats, boolean isIdleConnectionToServerCleanupEnabled, long idleConnectionCleanupThresholdMins)
static org.apache.http.nio.conn.ssl.SSLIOSessionStrategy	getSslStrategy(SSLFactory sslFactory)

Methods inherited from class java.lang.Object

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

Constructor Details

HttpClientUtils

public HttpClientUtils()

Method Details

getSslStrategy

public static org.apache.http.nio.conn.ssl.SSLIOSessionStrategy getSslStrategy(SSLFactory sslFactory)

getMinimalHttpClient

public static org.apache.http.impl.nio.client.CloseableHttpAsyncClient getMinimalHttpClient(int ioThreadNum,
 int maxConnPerRoute,
 int maxConnTotal,
 int socketTimeout,
 int connectionTimeout,
 Optional<SSLFactory> sslFactory,
 Optional<CachedDnsResolver> dnsResolver,
 Optional<HttpConnectionPoolStats> poolStats)

getMinimalHttpClientWithConnManager

public static HttpClientUtils.ClosableHttpAsyncClientWithConnManager getMinimalHttpClientWithConnManager(int ioThreadNum,
 int maxConnPerRoute,
 int maxConnTotal,
 int socketTimeout,
 int connectionTimeout,
 Optional<SSLFactory> sslFactory,
 Optional<CachedDnsResolver> dnsResolver,
 Optional<HttpConnectionPoolStats> poolStats,
 boolean isIdleConnectionToServerCleanupEnabled,
 long idleConnectionCleanupThresholdMins)

getMinimalHttpClient

public static org.apache.http.impl.nio.client.CloseableHttpAsyncClient getMinimalHttpClient(int ioThreadNum,
 int maxConnPerRoute,
 int maxConnTotal,
 int socketTimeout,
 int connectionTimeout,
 Optional<SSLFactory> sslFactory,
 Optional<CachedDnsResolver> dnsResolver,
 Optional<HttpConnectionPoolStats> poolStats,
 boolean isIdleConnectionToServerCleanupEnabled,
 long idleConnectionCleanupThresholdMins)

createConnectionManager

public static org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager createConnectionManager(int ioThreadNum,
 int perRoute,
 int total,
 int soTimeout,
 int connectionTimeout,
 Optional<SSLFactory> sslFactory,
 Optional<CachedDnsResolver> dnsResolver,
 Optional<HttpConnectionPoolStats> poolStats)

getMinimalHttpClient

public static org.apache.http.impl.nio.client.CloseableHttpAsyncClient getMinimalHttpClient(int maxConnPerRoute,
 int maxConnTotal,
 Optional<SSLFactory> sslFactory)

This function is only being used in test cases.

Parameters:

maxConnPerRoute -

maxConnTotal -

sslFactory -

Returns: