com.netflix.discovery.shared.transport

Interface EurekaTransportConfig

All Known Implementing Classes:

DefaultEurekaTransportConfig

public interface EurekaTransportConfig

Config class that governs configurations relevant to the transport layer

Method Summary

Modifier and Type	Method and Description
boolean	applicationsResolverUseIp() By default, the applications resolver extracts the public hostname from internal InstanceInfos for resolutions.
int	getApplicationsResolverDataStalenessThresholdSeconds()
int	getAsyncExecutorThreadPoolSize()
int	getAsyncResolverRefreshIntervalMs()
int	getAsyncResolverWarmUpTimeoutMs()
java.lang.String	getBootstrapResolverStrategy() Can be used to specify different bootstrap resolve strategies.
java.lang.String	getReadClusterVip() The remote vipAddress of the eureka cluster (either the primaries or a readonly replica) to fetch registry data from.
double	getRetryableClientQuarantineRefreshPercentage()
int	getSessionedClientReconnectIntervalSeconds()
java.lang.String	getWriteClusterVip() The remote vipAddress of the primary eureka cluster to register with.
boolean	useBootstrapResolverForQuery() By default, the transport uses the same (bootstrap) resolver for queries.

Method Detail

getSessionedClientReconnectIntervalSeconds

int getSessionedClientReconnectIntervalSeconds()

Returns:

the reconnect inverval to use for sessioned clients

getRetryableClientQuarantineRefreshPercentage

double getRetryableClientQuarantineRefreshPercentage()

Returns:

the percentage of the full endpoints set above which the quarantine set is cleared in the range [0, 1.0]

getApplicationsResolverDataStalenessThresholdSeconds

int getApplicationsResolverDataStalenessThresholdSeconds()

Returns:

the max staleness threshold tolerated by the applications resolver

applicationsResolverUseIp

boolean applicationsResolverUseIp()

By default, the applications resolver extracts the public hostname from internal InstanceInfos for resolutions. Set this to true to change this behaviour to use ip addresses instead (private ip if ip type can be determined).

Returns:

false by default

getAsyncResolverRefreshIntervalMs

int getAsyncResolverRefreshIntervalMs()

Returns:

the interval to poll for the async resolver.

getAsyncResolverWarmUpTimeoutMs

int getAsyncResolverWarmUpTimeoutMs()

Returns:

the async refresh timeout threshold in ms.

getAsyncExecutorThreadPoolSize

int getAsyncExecutorThreadPoolSize()

Returns:

the max threadpool size for the async resolver's executor

getWriteClusterVip

java.lang.String getWriteClusterVip()

The remote vipAddress of the primary eureka cluster to register with.

Returns:

the vipAddress for the write cluster to register with

getReadClusterVip

java.lang.String getReadClusterVip()

The remote vipAddress of the eureka cluster (either the primaries or a readonly replica) to fetch registry data from.

Returns:

the vipAddress for the readonly cluster to redirect to, if applicable (can be the same as the bootstrap)

getBootstrapResolverStrategy

java.lang.String getBootstrapResolverStrategy()

Can be used to specify different bootstrap resolve strategies. Current supported strategies are: - default (if no match): bootstrap from dns txt records or static config hostnames - composite: bootstrap from local registry if data is available and warm (see getApplicationsResolverDataStalenessThresholdSeconds(), otherwise fall back to a backing default

Returns:

null for the default strategy, by default

useBootstrapResolverForQuery

boolean useBootstrapResolverForQuery()

By default, the transport uses the same (bootstrap) resolver for queries. Set this property to false to use an indirect resolver to resolve query targets via getReadClusterVip(). This indirect resolver may or may not return the same targets as the bootstrap servers depending on how servers are setup.

Returns:

true by default.